Pass worker_task_queue to the create-tools API

Author: jnkrmg

application_sdk/application/__init__.py

@@ -163,6 +163,7 @@ async def _register_activities_with_delay():
             await asyncio.to_thread(
                 flush_activity_registrations,
                 app_name=self.application_name,
+                workflow_task_queue=self.workflow_client.worker_task_queue,
                 activity_specs=ACTIVITY_SPECS,
             )
 

application_sdk/decorators/automation_activity.py

@@ -133,6 +133,7 @@ def decorator(func: Callable[..., Any]) -> Callable[..., Any]:
 
 def flush_activity_registrations(
     app_name: str,
+    workflow_task_queue: str,
     activity_specs: List[dict[str, Any]],
 ) -> None:
     """Flush all collected registrations by calling the activities create API via HTTP."""
@@ -181,6 +182,7 @@ def flush_activity_registrations(
     payload = {
         "app_qualified_name": app_qualified_name,
         "app_name": app_name,
+        "workflow_task_queue": workflow_task_queue,
         "tools": tools,
     }