• b

    brian

    7 months ago
    Hi all, I’m trying to use a secret in a state handler but it doesn’t seem to be working
    b
    Kevin Kho
    16 replies
    Copy to Clipboard
  • Mehdi Nazari

    Mehdi Nazari

    7 months ago
    Hey All, I’m having an issue with a flow that is registered with the Hybrid model approach where I have a docker image and the flow with a DockerConfig to run it from the cloud. This was working in a the past but as of a few days ago, flow run gets triggered but no run is being performed. This leaves the run in Submitted state with a few attempts to re-run and Lazarus service finally kills it. I have other flows registered/installed and working within the same environment so I a little puzzled as to why this flow does not run. Any debugging suggestion would be appreciated.
    Mehdi Nazari
    Kevin Kho
    3 replies
    Copy to Clipboard
  • Matthew Seligson

    Matthew Seligson

    7 months ago
    If a task run can be in a “Running” state multiple times in its lifetime, should there be an identifier that uniquely identifies a particular “run” of a task run? We could take task run ID + task_run_count to come up with an identifier for this, but I’m wondering if Prefect has thought about this or plans to support this in the future?
    Matthew Seligson
    1 replies
    Copy to Clipboard
  • s

    Scott Aefsky

    7 months ago
    Hi all. I have a couple of ETL flows that are going to run on a large quantity of data the first time they run, but much smaller datasets every subsequent run. What I want to do is run with a DaskExecutor on the first run, but a default executor on subsequent runs. I was wondering if it's possible to choose an executor at runtime based on a parameter, or if there is another way to achieve what I'm looking for without having multiple flows. Thanks!
    s
    Kevin Kho
    8 replies
    Copy to Clipboard
  • Jacqueline Riley Garrahan

    Jacqueline Riley Garrahan

    7 months ago
    Is there an alternative/direct way to get all flow runs via flow id besides:
    runs = FlowRunView._query_for_flow_run(where={"flow_id": {"_eq": id}})
    Jacqueline Riley Garrahan
    1 replies
    Copy to Clipboard
  • Constantino Schillebeeckx

    Constantino Schillebeeckx

    7 months ago
    I'm running flows on ECS using fargate; is it normal to see
    RUNNING
    tasks like those shown below which have been running for days? Are those truly still running? Am I being billed for idle compute here?
    Constantino Schillebeeckx
    Anna Geller
    18 replies
    Copy to Clipboard
  • c

    Chris Martinez

    7 months ago
    Hi all, I am running into an issue when running a flow where the repository is no longer accessible when upgrading to
    0.15.12
    from
    0.14.21
    Failed to load and execute Flow's environment: NotGitRepository('No git repository was found ...
    I am using the git storage interface and have no issues when using version
    0.14.21
    c
    1 replies
    Copy to Clipboard
  • Matthias

    Matthias

    7 months ago
    Stupid question, is there an equivalent of
    prefect run
    in Orion? Or do you have to run flows with
    python flow.py
    ?
    Matthias
    Anna Geller
    2 replies
    Copy to Clipboard
  • Lee Cullen

    Lee Cullen

    7 months ago
    Hey all, I'm getting the following error when I try to run a flow via cloud using Bitbucket storage config:
    Failed to load and execute Flow's environment: ValueError('No flows found in file.')
    . The flow context manager is defined within the body of a function that returns a flow, I'm wondering if that is the reason why cloud can't find the flow?
    Lee Cullen
    Anna Geller
    +1
    12 replies
    Copy to Clipboard
  • Leon Kozlowski

    Leon Kozlowski

    7 months ago
    Does the DbtShellTask work with the open-lineage dbt? (
    dbt-ol run
    )
    Leon Kozlowski
    Anna Geller
    +1
    5 replies
    Copy to Clipboard