We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eae6e9f commit 019fce1Copy full SHA for 019fce1
workflow_task_multiprocessing/starter.py
@@ -32,7 +32,6 @@ async def main():
32
wf_handles = [
33
client.execute_workflow(
34
ParallelizedWorkflow.run,
35
- "temporal",
36
id=f"greeting-workflow-id-{uuid.uuid4()}",
37
task_queue=WORKFLOW_TASK_QUEUE,
38
)
workflow_task_multiprocessing/workflows.py
@@ -10,7 +10,7 @@
10
@workflow.defn
11
class ParallelizedWorkflow:
12
@workflow.run
13
- async def run(self, input: str) -> str:
+ async def run(self) -> str:
14
pid = os.getpid()
15
activity_result = await workflow.execute_activity(
16
echo_pid_activity,
0 commit comments