in http_logs/workload.py [0:0]
def register(registry):
async_runner = registry.meta_data.get("async_runner", False)
if async_runner:
registry.register_runner("reindex", reindex_async, async_runner=True)
else:
registry.register_runner("reindex", reindex)
registry.register_workload_processor(RuntimeFieldResolver())
try:
registry.register_workload_processor(loader.DefaultWorkloadPreparator())
except TypeError as e:
if e == "__init__() missing 1 required positional argument: 'cfg'":
pass