Function
target_wrapped
(process_id, *args, **kwargs)
Source from the content-addressed store, hash-verified
| 709 | run_id = uuid.uuid4() |
| 710 | |
| 711 | def target_wrapped(process_id, *args, **kwargs): |
| 712 | os.environ["PATHWAY_PROCESSES"] = str(processes) |
| 713 | os.environ["PATHWAY_FIRST_PORT"] = str(first_port) |
| 714 | os.environ["PATHWAY_PROCESS_ID"] = str(process_id) |
| 715 | os.environ["PATHWAY_RUN_ID"] = str(run_id) |
| 716 | target(*args, **kwargs) |
| 717 | |
| 718 | for process_id in range(processes): |
| 719 | p = multiprocessing.Process( |
Callers
nothing calls this directly
Tested by
no test coverage detected