@@ -384,22 +384,24 @@ func WithLocalActivityTask(
384384 deadline = task .expireTime
385385 }
386386 return newActivityContext (ctx , interceptors , & activityEnvironment {
387- workflowType : & workflowTypeLocal ,
388- workflowNamespace : task .params .WorkflowInfo .Namespace ,
389- taskQueue : task .params .WorkflowInfo .TaskQueueName ,
390- activityType : ActivityType {Name : activityType },
391- activityID : fmt .Sprintf ("%v" , task .activityID ),
392- workflowExecution : task .params .WorkflowInfo .WorkflowExecution ,
393- logger : logger ,
394- metricsHandler : metricsHandler ,
395- isLocalActivity : true ,
396- deadline : deadline ,
397- scheduledTime : task .scheduledTime ,
398- startedTime : startedTime ,
399- dataConverter : dataConverter ,
400- attempt : task .attempt ,
401- client : client ,
402- workerStopChannel : workerStopChannel ,
387+ workflowType : & workflowTypeLocal ,
388+ workflowNamespace : task .params .WorkflowInfo .Namespace ,
389+ taskQueue : task .params .WorkflowInfo .TaskQueueName ,
390+ activityType : ActivityType {Name : activityType },
391+ activityID : fmt .Sprintf ("%v" , task .activityID ),
392+ workflowExecution : task .params .WorkflowInfo .WorkflowExecution ,
393+ logger : logger ,
394+ metricsHandler : metricsHandler ,
395+ scheduleToCloseTimeout : scheduleToCloseTimeout ,
396+ startToCloseTimeout : startToCloseTimeout ,
397+ isLocalActivity : true ,
398+ deadline : deadline ,
399+ scheduledTime : task .scheduledTime ,
400+ startedTime : startedTime ,
401+ dataConverter : dataConverter ,
402+ attempt : task .attempt ,
403+ client : client ,
404+ workerStopChannel : workerStopChannel ,
403405 })
404406}
405407
0 commit comments