jamodes
11/12/2020, 11:33 AMDave
11/12/2020, 12:16 PMjamodes
11/12/2020, 3:40 PM....
....
with Flow("Map / Reduce 🤓", schedule=CronSchedule("20 10 * * *")) as flow:
numbers = numbers_task()
first_map = map_task.map(numbers)
second_map = map_task.map(first_map)
reduction = reduce_task(second_map)
flow.register(project_name='test')
Dave
11/13/2020, 12:30 PMprefect backend server
3. prefect server start
4. Create Tenant and Project (test)
5. prefect agent start local
6. Ran your script as above
7. Waited for it to be scheduled
Then I can only think of that you might registered the flow with a different version than the prefect version you currently are running.
I would recommend that you update prefect, kill your existing prefect local server and start it again and register the flow again.