fix: wait for resource attributes

docker-compose.yml

@@ -173,8 +173,8 @@ configs:
   prometheus-config:
     content: |
       global:
-        evaluation_interval: 30s
-        scrape_interval: 10s
+        evaluation_interval: 15s
+        scrape_interval: 15s
       scrape_configs:
         - job_name: otel-collector
           static_configs:

yarn-project/aztec/src/cli/cmds/start_archiver.ts

@@ -25,7 +25,7 @@ export const startArchiver = async (options: any, signalHandlers: (() => Promise
   const store = await createStore(archiverConfig, rollupAddress, storeLog);
   const archiverStore = new KVArchiverDataStore(store, archiverConfig.maxLogs);
 
-  const telemetry = createAndStartTelemetryClient(getTelemetryClientConfig());
+  const telemetry = await createAndStartTelemetryClient(getTelemetryClientConfig());
   const archiver = await Archiver.createAndSync(archiverConfig, archiverStore, telemetry, true);
   const archiverServer = createArchiverRpcServer(archiver);
   services.push({ archiver: archiverServer });

yarn-project/aztec/src/cli/cmds/start_node.ts

@@ -91,7 +91,7 @@ export const startNode = async (
   }
 
   const telemetryConfig = extractRelevantOptions<TelemetryClientConfig>(options, telemetryClientConfigMappings, 'tel');
-  const telemetryClient = createAndStartTelemetryClient(telemetryConfig);
+  const telemetryClient = await createAndStartTelemetryClient(telemetryConfig);
 
   // Create and start Aztec Node.
   const node = await createAztecNode(nodeConfig, telemetryClient);

yarn-project/aztec/src/cli/cmds/start_prover_agent.ts

@@ -21,7 +21,7 @@ export const startProverAgent: ServiceStarter = async (options, signalHandlers,
   const source = createProvingJobSourceClient(proverConfig.nodeUrl, 'provingJobSource');
 
   const telemetryConfig = extractRelevantOptions<TelemetryClientConfig>(options, telemetryClientConfigMappings, 'tel');
-  const telemetry = createAndStartTelemetryClient(telemetryConfig);
+  const telemetry = await createAndStartTelemetryClient(telemetryConfig);
 
   let circuitProver: ServerCircuitProver;
   if (proverConfig.realProofs) {

yarn-project/aztec/src/cli/cmds/start_prover_node.ts

@@ -70,7 +70,7 @@ export const startProverNode = async (
     proverConfig.l1Contracts = await createAztecNodeClient(nodeUrl).getL1ContractAddresses();
   }
 
-  const telemetry = createAndStartTelemetryClient(getTelemetryClientConfig());
+  const telemetry = await createAndStartTelemetryClient(getTelemetryClientConfig());
   const proverNode = await createProverNode(proverConfig, { telemetry });
 
   services.push({ node: createProverNodeRpcServer(proverNode) });

yarn-project/aztec/src/sandbox.ts

@@ -170,7 +170,7 @@ export async function createSandbox(config: Partial<SandboxConfig> = {}) {
     await deployContractsToL1(aztecNodeConfig, hdAccount);
   }
 
-  const client = createAndStartTelemetryClient(getTelemetryClientConfig());
+  const client = await createAndStartTelemetryClient(getTelemetryClientConfig());
   const node = await createAztecNode(aztecNodeConfig, client);
   const pxe = await createAztecPXE(node);
 

yarn-project/end-to-end/src/fixtures/snapshot_manager.ts

@@ -325,7 +325,7 @@ async function setupFromFresh(
     aztecNodeConfig.bbWorkingDirectory = bbConfig.bbWorkingDirectory;
   }
 
-  const telemetry = createAndStartTelemetryClient(getTelemetryConfig());
+  const telemetry = await createAndStartTelemetryClient(getTelemetryConfig());
   logger.verbose('Creating and synching an aztec node...');
   const aztecNode = await AztecNodeService.createAndSync(aztecNodeConfig, telemetry);
 
@@ -408,7 +408,7 @@ async function setupFromState(statePath: string, logger: Logger): Promise<Subsys
   const { publicClient, walletClient } = createL1Clients(aztecNodeConfig.l1RpcUrl, mnemonicToAccount(MNEMONIC));
 
   logger.verbose('Creating aztec node...');
-  const telemetry = createAndStartTelemetryClient(getTelemetryConfig());
+  const telemetry = await createAndStartTelemetryClient(getTelemetryConfig());
   const aztecNode = await AztecNodeService.createAndSync(aztecNodeConfig, telemetry);
 
   const proverNodePrivateKey = getPrivateKeyFromIndex(2);

yarn-project/end-to-end/src/fixtures/utils.ts

@@ -90,10 +90,11 @@ export { deployAndInitializeTokenAndBridgeContracts } from '../shared/cross_chai
 
 const { PXE_URL = '' } = process.env;
 
-const telemetry = createAndStartTelemetryClient(getTelemetryConfig());
+const telemetryPromise = createAndStartTelemetryClient(getTelemetryConfig());
 if (typeof afterAll === 'function') {
   afterAll(async () => {
-    await telemetry.stop();
+    const client = await telemetryPromise;
+    await client.stop();
   });
 }
 
@@ -395,6 +396,7 @@ export async function setup(
   }
   config.l1PublishRetryIntervalMS = 100;
 
+  const telemetry = await telemetryPromise;
   const aztecNode = await AztecNodeService.createAndSync(config, telemetry);
   const sequencer = aztecNode.getSequencer();
 

yarn-project/telemetry-client/src/otel.ts

@@ -62,26 +62,19 @@ export class OpenTelemetryClient implements TelemetryClient {
       description: 'Target information',
     });
 
-    if (this.resource.asyncAttributesPending) {
-      void this.resource.waitForAsyncAttributes!().then(() => {
-        this.targetInfo!.record(1, this.resource.attributes);
-      });
-    } else {
-      this.targetInfo.record(1, this.resource.attributes);
-    }
-
+    this.targetInfo.record(1, this.resource.attributes);
     this.hostMetrics.start();
   }
 
   public async stop() {
     await Promise.all([this.meterProvider.shutdown()]);
   }
 
-  public static createAndStart(
+  public static async createAndStart(
     metricsCollector: URL,
     tracesCollector: URL | undefined,
     log: DebugLogger,
-  ): OpenTelemetryClient {
+  ): Promise<OpenTelemetryClient> {
     const resource = detectResourcesSync({
       detectors: [
         osDetectorSync,
@@ -94,6 +87,10 @@ export class OpenTelemetryClient implements TelemetryClient {
       ],
     });
 
+    if (resource.asyncAttributesPending) {
+      await resource.waitForAsyncAttributes!();
+    }
+
     const tracerProvider = new NodeTracerProvider({
       resource,
     });
@@ -105,6 +102,7 @@ export class OpenTelemetryClient implements TelemetryClient {
 
     tracerProvider.register();
 
+    console.log('pushing metrics to', metricsCollector.href);
     const meterProvider = new MeterProvider({
       resource,
       readers: [

yarn-project/telemetry-client/src/start.ts

@@ -7,11 +7,11 @@ import { type TelemetryClient } from './telemetry.js';
 
 export * from './config.js';
 
-export function createAndStartTelemetryClient(config: TelemetryClientConfig): TelemetryClient {
+export async function createAndStartTelemetryClient(config: TelemetryClientConfig): Promise<TelemetryClient> {
   const log = createDebugLogger('aztec:telemetry-client');
   if (config.metricsCollectorUrl) {
     log.info('Using OpenTelemetry client');
-    return OpenTelemetryClient.createAndStart(config.metricsCollectorUrl, config.tracesCollectorUrl, log);
+    return await OpenTelemetryClient.createAndStart(config.metricsCollectorUrl, config.tracesCollectorUrl, log);
   } else {
     log.info('Using NoopTelemetryClient');
     return new NoopTelemetryClient();