• Danny Vilela

    Danny Vilela

    1 year ago
    Hi, sorry to bother again: does setting a task’s
    timeout
    work in conjunction with
    max_retries
    ? Is a “timeout” the same as a “failure”?
    Danny Vilela
    Kevin Kho
    2 replies
    Copy to Clipboard
  • Chris L.

    Chris L.

    1 year ago
    Hello Prefect community! Just a quick question: is there a simple convenience function to check if a flow has been successfully registered? (e.g.
    flow.is_registered()
    ). Otherwise, is there a gist for using
    prefect.client
    and working with the graphql response? Thanks in advance
    Chris L.
    Kevin Kho
    6 replies
    Copy to Clipboard
  • a

    Arran

    1 year ago
    Quick question. Is there a simple way to run a flow via an API endpoint rather than scheduled within prefect?
    a
    Bouke Krom
    3 replies
    Copy to Clipboard
  • Samuel Tober

    Samuel Tober

    1 year ago
    Hi! I am trying to call a task inside a for-loop, but keep getting the following error:
    TypeError: Task is not iterable.
    Samuel Tober
    Yueh-Han
    +1
    9 replies
    Copy to Clipboard
  • Samuel Tober

    Samuel Tober

    1 year ago
    What is the recommended way to go about this?
  • Didier Marin

    Didier Marin

    1 year ago
    Hi ! As anyone tried to validate the parameters of a flow using a Pydandic model or dataclasses ?
    Didier Marin
    Kevin Kho
    +1
    5 replies
    Copy to Clipboard
  • c

    Christian

    1 year ago
    Hi all 👋 I was wondering if there is something like a Mattermost notification task? I figured as there is a slack notifier something for Mattermost might be not so far off? Cheers, C
    c
    Kevin Kho
    +1
    3 replies
    Copy to Clipboard
  • Leon Kozlowski

    Leon Kozlowski

    1 year ago
    Does anyone have an example of rendering a matplotlib graph with the artifacts api?
    Leon Kozlowski
    Kevin Kho
    3 replies
    Copy to Clipboard
  • b

    Brad I

    1 year ago
    We’re using the k8s agent with dask executor on GKE with workload identities. Does anyone know if it is still required to set the
    GCP_CREDENTIALS
    secret in Prefect Cloud? Or will it just use the service account tied to the namespace? The latter would be nice to avoid creating any long lived service account keys.
    b
    Kevin Kho
    7 replies
    Copy to Clipboard
  • Rutvik Patel

    Rutvik Patel

    1 year ago
    Hey folks, I'm trying to do following but can't figure it out. Any kind of pointers will be appreciated. I want to build a pipeline where it loads a file larger than RAM my local machine have. I can do that with Dask alone, but not sure how to do that in prefect task. In other words, is it possible that the first task of a flow load a chunk of dataframe and once it processed, it will load next chunk and so on? Thanks.
    Rutvik Patel
    Kyle McChesney
    +1
    4 replies
    Copy to Clipboard