File tree Expand file tree Collapse file tree
workflow_task_multiprocessing Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11import os
2+
23from temporalio import activity
34
45
Original file line number Diff line number Diff line change 1- import asyncio
21import argparse
2+ import asyncio
33import uuid
44
55from temporalio .client import Client
Original file line number Diff line number Diff line change 11import argparse
2+ import asyncio
23import concurrent .futures
34import dataclasses
45import multiprocessing
56import traceback
6- import asyncio
77from typing import Literal
88
99from temporalio .client import Client
1010from temporalio .envconfig import ClientConfig
11- from temporalio .worker import Worker , PollerBehaviorSimpleMaximum
11+ from temporalio .runtime import Runtime , TelemetryConfig
12+ from temporalio .worker import PollerBehaviorSimpleMaximum , Worker
1213from temporalio .worker .workflow_sandbox import (
1314 SandboxedWorkflowRunner ,
1415 SandboxRestrictions ,
1516)
16- from temporalio .runtime import Runtime , TelemetryConfig
1717
1818from workflow_task_multiprocessing import ACTIVITY_TASK_QUEUE , WORKFLOW_TASK_QUEUE
19- from workflow_task_multiprocessing .workflows import ParallelizedWorkflow
2019from workflow_task_multiprocessing .activities import echo_pid_activity
21-
20+ from workflow_task_multiprocessing . workflows import ParallelizedWorkflow
2221
2322# Immediately prevent the default Runtime from being created to ensure
2423# each process creates it's own
@@ -49,7 +48,7 @@ def main():
4948 try :
5049 mp_ctx = multiprocessing .get_context ("fork" )
5150 except ValueError :
52- mp_ctx = multiprocessing .get_context ("spawn" )
51+ mp_ctx = multiprocessing .get_context ("spawn" ) # type: ignore
5352
5453 with concurrent .futures .ProcessPoolExecutor (
5554 args .total_workers , mp_context = mp_ctx
Original file line number Diff line number Diff line change 1- from datetime import timedelta
21import os
2+ from datetime import timedelta
33
44from temporalio import workflow
55
You can’t perform that action at this time.
0 commit comments