鹿野孟城
06/30/2025, 12:24 AMMarvin
06/30/2025, 12:24 AMMarvin
06/30/2025, 12:26 AMbash
prefect deployment list-schedulespython
from prefect.client import get_client
async with get_client() as client:
    # Replace deployment_id with your actual deployment ID
    scheduled_runs = await client.get_scheduled_flow_runs_for_deployments(
        deployment_ids=["your-deployment-id"]
    )list-schedulesbash
prefect deployment inspect "deployment-name/deployment-tag"鹿野孟城
06/30/2025, 5:59 AMMarvin
06/30/2025, 5:59 AMMarvin
06/30/2025, 6:00 AMpython
@flow
def process_data(data_url: str):  # Pass reference instead of data
    # Download or access data inside the flow
    data = download_data(data_url)
    # Process the data
    process(data)python
@flow
def process_data(large_data: bytes):  # Not recommended for large data
    process(large_data)鹿野孟城
06/30/2025, 6:06 AMFlow run parameters cannot exceedthis note have mentioned on prefect 3 docs. is this correct?in size.512kb
Marvin
06/30/2025, 6:07 AMMarvin
06/30/2025, 6:07 AMpython
@flow
def process_large_data(file_path: str):  # Pass file path instead of data
    # Read and process data inside the flow
    with open(file_path, 'rb') as f:
        data = f.read()
    process(data)