fix poller

Author: nicktrn

packages/cli-v3/src/entryPoints/managed-run-controller.ts

@@ -108,7 +108,7 @@ class ManagedRunController {
       httpClient: this.httpClient,
       logger: this.logger,
       snapshotPollIntervalSeconds: this.snapshotPollIntervalSeconds,
-      handleSnapshotChange: this.handleSnapshotChange,
+      handleSnapshotChange: this.handleSnapshotChange.bind(this),
     });
 
     this.runHeartbeat = new RunExecutionHeartbeat({

packages/cli-v3/src/entryPoints/managed/heartbeat.ts

@@ -25,6 +25,16 @@ export class RunExecutionHeartbeat {
     this.runFriendlyId = opts.runFriendlyId;
     this.snapshotFriendlyId = opts.snapshotFriendlyId;
 
+    this.logger.sendDebugLog({
+      runId: this.runFriendlyId,
+      message: "RunExecutionHeartbeat",
+      properties: {
+        runFriendlyId: this.runFriendlyId,
+        snapshotFriendlyId: this.snapshotFriendlyId,
+        heartbeatIntervalSeconds: opts.heartbeatIntervalSeconds,
+      },
+    });
+
     this.heartbeat = new HeartbeatService({
       heartbeat: async () => {
         this.logger.sendDebugLog({

packages/cli-v3/src/entryPoints/managed/poller.ts

@@ -19,18 +19,22 @@ export class RunExecutionSnapshotPoller {
   private readonly runFriendlyId: string;
   private snapshotFriendlyId: string;
 
-  private readonly snapshotPollIntervalSeconds: number;
-
-  private readonly handleSnapshotChange: (execution: RunExecutionData) => Promise<void>;
-
   constructor(opts: RunExecutionSnapshotPollerOptions) {
     this.logger = opts.logger;
     this.httpClient = opts.httpClient;
 
     this.runFriendlyId = opts.runFriendlyId;
     this.snapshotFriendlyId = opts.snapshotFriendlyId;
 
-    this.handleSnapshotChange = opts.handleSnapshotChange;
+    this.logger.sendDebugLog({
+      runId: this.runFriendlyId,
+      message: "RunExecutionSnapshotPoller",
+      properties: {
+        runFriendlyId: this.runFriendlyId,
+        snapshotFriendlyId: this.snapshotFriendlyId,
+        snapshotPollIntervalSeconds: opts.snapshotPollIntervalSeconds,
+      },
+    });
 
     this.poller = new HeartbeatService({
       heartbeat: async () => {
@@ -78,9 +82,9 @@ export class RunExecutionSnapshotPoller {
           return;
         }
 
-        await this.handleSnapshotChange(response.data.execution);
+        await opts.handleSnapshotChange(response.data.execution);
       },
-      intervalMs: this.snapshotPollIntervalSeconds * 1000,
+      intervalMs: opts.snapshotPollIntervalSeconds * 1000,
       leadingEdge: false,
       onError: async (error) => {
         this.logger.sendDebugLog({