Khuyen Tran
import asyncio from prefect import flow, get_run_logger @flow async def test_async_flow(): await asyncio.sleep(3) logger = get_run_logger() logger.debug("a debug") <http://logger.info|logger.info>("my info") logger.warning("some warning") logger.critical("super critical") logger.error("error!") print('all done') @flow def test_sync_flow(): test_async_flow() test_sync_flow()
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.