Remote function call that uses cloudpickle to transport everthing
(payload, protocol)
| 126 | |
| 127 | |
| 128 | def call_func(payload, protocol): |
| 129 | """Remote function call that uses cloudpickle to transport everthing""" |
| 130 | func, args, kwargs = loads(payload) |
| 131 | try: |
| 132 | result = func(*args, **kwargs) |
| 133 | except BaseException as e: |
| 134 | result = e |
| 135 | return dumps(result, protocol=protocol) |
| 136 | |
| 137 | |
| 138 | class _Worker: |
nothing calls this directly
no test coverage detected
searching dependent graphs…