James Phoenix
Kevin Kho
from prefect.deployments import DeploymentSpec from prefect import flow, get_run_logger from prefect.blocks.storage import GoogleCloudStorageBlock storage_block = GoogleCloudStorageBlock( bucket='prefect_source_data', project='marketingsimulations', ) @flow(name="Testing") def basic_flow(): logger = get_run_logger() logger.warning("The fun is about to begin") DeploymentSpec( flow=basic_flow, name="Test Deployment", tags=['tutorial', 'test'], flow_storage=storage_block )
export GOOGLE_APPLICATION_CREDENTIALS=service-account.json
Marvin
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.