in nyc_taxis/workload.py [0:0]
def register(registry):
async_runner = registry.meta_data.get("async_runner", False)
if async_runner:
registry.register_runner("wait-for-ml-lookback", wait_for_ml_lookback_async, async_runner=True)
else:
registry.register_runner("wait-for-ml-lookback", wait_for_ml_lookback)