Tim Enders
06/09/2022, 2:51 PM@flow(name="Subscriptions Flow",
task_runner=DaskTaskRunner())
def main():
*snip*
pages_list = get_pages_list(client, "subscriptions", params)
for page in pages_list:
item_list = get_items_list(client, "subscriptions", page)
if __name__ == "__main__":
flow_result = main()
print(flow_result)
But I get a RuntimeError from the multiprocessing. Can I get some help on what I am doing wrong with the DaskRunner. I want to parallel run over what is in pages_list
Kevin Kho
06/09/2022, 2:53 PMTim Enders
06/09/2022, 2:54 PMZanie
06/09/2022, 2:56 PMpages_list.result()
Tim Enders
06/09/2022, 2:57 PM