Justin Trautmann
07/25/2022, 10:17 AMprefect deployment execute ...
fails with RuntimeWarning: coroutine 'create_then_begin_flow_run' was never awaited
. see thread for my flow code. thanks a lot for your support.import asyncio
from prefect import flow, get_run_logger
@flow()
async def test_flow():
logger = get_run_logger()
<http://logger.info|logger.info>("Running test flow")
async def main():
await test_flow()
if __name__ == "__main__":
asyncio.run(main())
Jeff Hale
07/25/2022, 4:59 PM