Derek
07/05/2024, 7:55 PMMarvin
07/05/2024, 7:55 PMfrom prefect import flow
@flow(log_prints=True) # Send `print` statements as INFO logs
def my_workflow():
print("I can call any python code here, including prefect tasks or flows")
if __name__ == "__main__":
my_workflow() # Call it like a normal python function
# or serve it as a long-lived process
# my_workflow.serve("my-deployment-name")
Example Link
For detailed, up-to-date instructions, it's best to consult the Prefect documentation directly or raise an issue in their GitHub repository.
- Documentation for Prefect: https://docs.prefect.io/
- GitHub issues: https://github.com/PrefectHQ/prefect/issues
You might specifically search for how to configure the database API or modify in-process settings under these resources. If direct documentation isn't clear, exploring Prefect configuration options or consulting the Prefect community could provide additional insights.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