Dani Lobaton
03/28/2024, 5:14 AMget_run_logger
to get the logger and put some info
logs to the console. However nothing shows up 😞
from prefect import flow, get_run_logger
from tasks.opportunities import fetch_first_page_opportunities, fetch_opportunities_page, compile_opportunities
@flow(name="Opportunity Pipeline", )
async def opportunity_pipeline():
"""Starts the opportunity pipeline."""
page_size = 400
logger = get_run_logger()
<http://logger.info|logger.info>(f"Starting the opportunity pipeline with a page size of {page_size}")
Prefect Cloud UI