(cmd, spec=None, task_id=None)
| 207 | |
| 208 | |
| 209 | def send_msg(cmd, spec=None, task_id=None): |
| 210 | msg = dict(command=cmd, spec=spec, task_id=task_id or get_current_task_id()) |
| 211 | get_current_session().send_task_command(msg) |
| 212 | |
| 213 | |
| 214 | def single_input_kwargs(single_input_return): |
no test coverage detected
searching dependent graphs…