Joeri Smits
01/03/2025, 2:20 PMfrom prefect import flow, get_run_logger
@flow
def master_flow():
logger = get_run_logger()
logger.setLevel("DEBUG")
logger.debug("Starting sync from Airbyte")
return "hello"
Marvin
01/03/2025, 2:20 PMJoeri Smits
01/03/2025, 3:25 PMMarvin
01/03/2025, 3:25 PMGitRepository
object or directly in the prefect.yaml
file for public repositories.
For more details on setting up Git-based storage with Prefect, you can refer to the Prefect documentation on storing flow code.
Remember to ensure that your Prefect worker environment is capable of executing Git commands and has access to the necessary credentials for private repositories.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