MCPcopy
hub / github.com/celery/celery / _waitexec

Method _waitexec

celery/apps/multi.py:212–221  ·  view source on GitHub ↗
(self, argv, path=sys.executable, env=None,
                  on_spawn=None, on_signalled=None, on_failure=None)

Source from the content-addressed store, hash-verified

210 self.argv, path=self.executable, env=env, **kwargs)
211
212 def _waitexec(self, argv, path=sys.executable, env=None,
213 on_spawn=None, on_signalled=None, on_failure=None):
214 argstr = self.prepare_argv(argv, path)
215 maybe_call(on_spawn, self, argstr=' '.join(argstr), env=env)
216 pipe = Popen(argstr, env=env)
217 return self.handle_process_exit(
218 pipe.wait(),
219 on_signalled=on_signalled,
220 on_failure=on_failure,
221 )
222
223 def handle_process_exit(self, retcode, on_signalled=None, on_failure=None):
224 if retcode < 0:

Callers 2

startMethod · 0.95
test_waitexecMethod · 0.80

Calls 5

prepare_argvMethod · 0.95
handle_process_exitMethod · 0.95
maybe_callFunction · 0.85
joinMethod · 0.45
waitMethod · 0.45

Tested by 1

test_waitexecMethod · 0.64