Add to child workflow / activity

Author: Sushisource

temporalio/worker/_interceptor.py

@@ -246,6 +246,7 @@ class StartActivityInput:
     headers: Mapping[str, temporalio.api.common.v1.Payload]
     disable_eager_execution: bool
     versioning_intent: Optional[VersioningIntent]
+    summary: Optional[str]
     # The types may be absent
     arg_types: Optional[List[Type]]
     ret_type: Optional[Type]

temporalio/worker/_workflow_instance.py

@@ -1159,6 +1159,7 @@ def workflow_start_activity(
         cancellation_type: temporalio.workflow.ActivityCancellationType,
         activity_id: Optional[str],
         versioning_intent: Optional[temporalio.workflow.VersioningIntent],
+        summary: Optional[str] = None,
     ) -> temporalio.workflow.ActivityHandle[Any]:
         self._assert_not_read_only("start activity")
         # Get activity definition if it's callable
@@ -1194,6 +1195,7 @@ def workflow_start_activity(
                 arg_types=arg_types,
                 ret_type=ret_type,
                 versioning_intent=versioning_intent,
+                summary=summary,
             )
         )
 
@@ -2369,6 +2371,8 @@ def _apply_schedule_command(
                 command.schedule_activity.versioning_intent = (
                     self._input.versioning_intent._to_proto()
                 )
+            # if self._input.summary:
+            #     command.
         if isinstance(self._input, StartLocalActivityInput):
             if self._input.local_retry_threshold:
                 command.schedule_local_activity.local_retry_threshold.FromTimedelta(

temporalio/workflow.py

@@ -659,6 +659,7 @@ def workflow_start_activity(
         cancellation_type: ActivityCancellationType,
         activity_id: Optional[str],
         versioning_intent: Optional[VersioningIntent],
+        summary: Optional[str] = None,
     ) -> ActivityHandle[Any]: ...
 
     @abstractmethod
@@ -1869,6 +1870,7 @@ def start_activity(
     cancellation_type: ActivityCancellationType = ActivityCancellationType.TRY_CANCEL,
     activity_id: Optional[str] = None,
     versioning_intent: Optional[VersioningIntent] = None,
+    summary: Optional[str] = None,
 ) -> ActivityHandle[Any]:
     """Start an activity and return its handle.
 
@@ -1902,6 +1904,8 @@ def start_activity(
             need to. Contact Temporal before setting this value.
         versioning_intent: When using the Worker Versioning feature, specifies whether this Activity
             should run on a worker with a compatible Build Id or not.
+        summary:  Gets or sets a single-line fixed summary for this activity that may appear in UI/CLI.
+            This can be in single-line Temporal markdown format.
 
     Returns:
         An activity handle to the activity which is an async task.
@@ -1919,6 +1923,7 @@ def start_activity(
         cancellation_type=cancellation_type,
         activity_id=activity_id,
         versioning_intent=versioning_intent,
+        summary=summary,
     )