fix(activity): Add missing Activity Info fields (#1187)

Author: mjameswh

packages/activity/src/index.ts

@@ -164,6 +164,10 @@ export interface Info {
    * Timeout for this Activity from start to close in milliseconds
    */
   startToCloseTimeoutMs: number;
+  /**
+   * Timestamp for when the current attempt of this Activity was scheduled in milliseconds
+   */
+  currentAttemptScheduledTimestampMs: number;
   /**
    * Heartbeat timeout in milliseconds.
    * If this timeout is defined, the Activity must heartbeat before the timeout is reached.

packages/testing/src/index.ts

@@ -376,13 +376,15 @@ export const defaultActivityInfo: activity.Info = {
   activityType: 'unknown',
   workflowType: 'test',
   base64TaskToken: Buffer.from('test').toString('base64'),
+  heartbeatTimeoutMs: undefined,
   heartbeatDetails: undefined,
   activityNamespace: 'default',
   workflowNamespace: 'default',
   workflowExecution: { workflowId: 'test', runId: 'dead-beef' },
   scheduledTimestampMs: 1,
   startToCloseTimeoutMs: 1000,
   scheduleToCloseTimeoutMs: 1000,
+  currentAttemptScheduledTimestampMs: 1,
 };
 
 /**

packages/worker/src/worker.ts

@@ -1828,11 +1828,13 @@ async function extractActivityInfo(
     isLocal: start.isLocal,
     activityType: start.activityType,
     workflowType: start.workflowType,
+    heartbeatTimeoutMs: start.heartbeatTimeout ? tsToMs(start.heartbeatTimeout) : undefined,
     heartbeatDetails: await decodeFromPayloadsAtIndex(dataConverter, 0, start.heartbeatDetails),
     activityNamespace,
     workflowNamespace: start.workflowNamespace,
     scheduledTimestampMs: tsToMs(start.scheduledTime),
     startToCloseTimeoutMs: tsToMs(start.startToCloseTimeout),
     scheduleToCloseTimeoutMs: tsToMs(start.scheduleToCloseTimeout),
+    currentAttemptScheduledTimestampMs: tsToMs(start.currentAttemptScheduledTime),
   };
 }