• Luis Aguirre

    Luis Aguirre

    8 months ago
    Hi, I'm trying to get the response of a flow run through the REST API. I'm using fetch(http://localhost:4200/api/flow_runs/${response.id}`` to fetch the data and just getting
    *data*: {encoding: 'orion', blob: '{"encoding": "file", "blob": "file:///tmp/78442fec16214918a437e768fa384762"}'}
    in the
    state
    section. Is there something I should configure to get the whole response? Thanks
    Luis Aguirre
    Kevin Kho
    6 replies
    Copy to Clipboard
  • Prateek Saigal

    Prateek Saigal

    8 months ago
    Hi, Just arrived. I have registered a flow and have added the CronSchedule. It gets scheduled on the right time but it is picking up the wrong date
    flow.schedule = CronSchedule("49 21 * * 1-5",start_date=pendulum.datetime(2022, 1, 1, tz="Asia/Kolkata"),)
    
    flow.register(
          project_name=project_name,
          idempotency_key=flow.serialized_hash(),
          labels=["test"],
        )
    What could be the reason for this?
    Prateek Saigal
    Kevin Kho
    9 replies
    Copy to Clipboard
  • Leon Kozlowski

    Leon Kozlowski

    8 months ago
    hi all - I upgraded the prefect version on one of my agents today, in the cloud ui I see two agents for the same label, however I am only seeing 1 agent pod on my k8s cluster, should I just remove this from the UI since the old pod no longer exists?
    Leon Kozlowski
    Kevin Kho
    3 replies
    Copy to Clipboard
  • Suresh R

    Suresh R

    8 months ago
    Hi, Why our cloud calendar is showing as empty even though we have few upcoming schedules?
    Suresh R
    Kevin Kho
    5 replies
    Copy to Clipboard
  • Seth Coussens

    Seth Coussens

    8 months ago
    Is it possible to get a task to show it's underlying function definition for intellisense in dev tools? For example the decorated function (with @task) is always just considered an Any type, so it doesn't show what variables it's expecting. (see screenshots) I'm hoping there is a way to show what variables it expects, so that when I build the task in one script and use it in a parent or child script I can see what inputs it expects. The way a normal function works (see last screenshot).
    Seth Coussens
    Kevin Kho
    6 replies
    Copy to Clipboard
  • Leon Kozlowski

    Leon Kozlowski

    8 months ago
    If a task returns a tuple, does that count as 2 task runs?
    Leon Kozlowski
    Kevin Kho
    +1
    10 replies
    Copy to Clipboard
  • Jason Motley

    Jason Motley

    8 months ago
    What is the best way to store a byte object as a secret and read it in during prefect? Example attached that is erroring out:
    Jason Motley
    Kevin Kho
    4 replies
    Copy to Clipboard
  • Matthew Millendorf

    Matthew Millendorf

    8 months ago
    Hi, I am looking to get all logs for a specific task run, not just the flow run. Any help would be great, bit stuck.
    Matthew Millendorf
    Kevin Kho
    6 replies
    Copy to Clipboard
  • Tim Enders

    Tim Enders

    8 months ago
    My brain is fried (yay Friday) and I can't seem to find this in the documentation. But how do I specify an upstream task explicitly when using the
    with Flow() as flow:
    pattern?
    Tim Enders
    Kevin Kho
    5 replies
    Copy to Clipboard
  • m

    Michael Bell

    8 months ago
    Hey folks. I am having a really hard time with dependency resolution between
    prefect
    and
    dask-cloudprovider
    right now. It seems
    dask-cloudprovider[aws]
    relies on
    aiobotocore
    which pins to a very specific
    botocore
    version and that's causing conflicts when trying to set up my environment. Anyone have any experience with this?
    m
    Kevin Kho
    +1
    12 replies
    Copy to Clipboard