Thanks Chris. I fixed the scope. But now when I run my flow with LocalDaskexecutor and schedule ,my tasks are not running.Here is my code:@task
def say_hello():
print("Hello, world!")
logger = prefect.context.get("logger")
logger.info("Hello, world!")
schedule = Schedule(clocks=[IntervalClock(start_date=pendulum.datetime(2020, 12, 16,hour=2,minute=14,second=0),interval=timedelta(minutes=2))])
with Flow("Hello",schedule) as flow:
say_hello()
executor=LocalDaskExecutor(scheduler="processes", num_workers=6)
flow.run(executor=executor)