luke
12/11/2023, 6:56 PMMarvin
12/11/2023, 6:57 PMJake Kaplan
12/11/2023, 7:04 PM@flow
def my_func():
...
my_func() # <-- will run on import
@flow
def my_func()
...
if __name__ == '__main__':
my_func() # <-- won't run on import
luke
12/11/2023, 7:08 PM# flow.py
@flow
def my_func():
...
my_func() # I still had this line in the code from development
Then
# execute.py
from flow import my_func
if __name__ == '__main__':
my_func.serve(cron="blah")
Guess that lingering my_func()
in flow.py
was inadvertently kicking it off immediately before returning to a scheduled format.Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by