• e

    Eddie Atkinson

    11 months ago
    Hi folks, I am looking at interfacing with prefect’s graphql API using Typescript and was wondering if the schema for Prefect’s API is available anywhere? Ideally I’d like to autogenerate typescript types for the queries, mutations etc. I’ve tried using
    graphql-code-generator
    but that hasn’t worked so far
    e
    Anna Geller
    7 replies
    Copy to Clipboard
  • haf

    haf

    11 months ago
    What's the recommended way to add monitoring and observability to a prefect flow? I mean: • the ability to see input-output for tasks (at least for a while after running them; just not Results) • the ability to see timings for each task • any structured logging from inside tasks (e.g. especially important segment variables / which app / tenant is it running for) • integrating with Prometheus ?
    haf
    Anna Geller
    2 replies
    Copy to Clipboard
  • a

    Adrien B

    11 months ago
    Hi everyone, I am trying to define a new flow. In this flow I have a task that I map on thousands of values. The problem is that some children tasks fail because there are too many open connections simultaneously. When I run my flow on 1000 arguments it works fine but on 8000, some child tasks are stuck in a running state. Is there a way to do the mapping consecutively by chunks of 1000 arguments ? Basically, If I give a parameter list of 5000 arguments to my flow, I would like the flow to run the task five times consecutively. Each time the task would me mapped over 1000 arguments. I don’t have to use the results of the tasks if that would be an issue. The flow would run on a localdaskexecutor with 15 proceseses and use a prefect server as an endpoint/host. Thank you so much for your help guys
    a
    Anna Geller
    +1
    6 replies
    Copy to Clipboard
  • t

    Toprak Nihat Deniz Öztürk

    11 months ago
    Can I access results of a flow run created with create_flow_run. I normally start child runs with
    f_run = flow.run
    method and access the results with
    f_run.results[df].result
    .
    t
    Kevin Kho
    3 replies
    Copy to Clipboard
  • Thomas Furmston

    Thomas Furmston

    11 months ago
    Hi. Sorry to ask such a basic question, but is it possible to delete a flow from the prefect server? I would like to do it programmatically, but I can't find any reference to it the documentation. I also can't see this option in the prefect cloud webUI.
    Thomas Furmston
    Kevin Kho
    8 replies
    Copy to Clipboard
  • João Luiz Carabetta

    João Luiz Carabetta

    11 months ago
    Hi, I was just trying the prefect orion tutorial (https://orion-docs.prefect.io/tutorials/first-steps/) but it failed 😕 It failed on this line
    state = my_favorite_function()
    João Luiz Carabetta
    3 replies
    Copy to Clipboard
  • Sahil Chopra

    Sahil Chopra

    11 months ago
    Hi everyone, when creating an
    EmailTask
    what is the
    EMAIL_USERNAME
    and
    EMAIL_PASSWORD
    used for? Are the notifications shipped from this email? Is this required, or is it possible to use the default notifications@prefect.io email address shown in the class definition?
    Sahil Chopra
    Kevin Kho
    4 replies
    Copy to Clipboard
  • h

    Hugo Kitano

    11 months ago
    Hi, I’m trying to ping the graphql API with python and javascript and running into some parsing problems. How would I convert the following to python using the requests package?
    query {
      flow_run(where: {name: {_eq: "woodoo-leopard"}}) {
        id
        state
        start_time
      }
    }
    h
    Kevin Kho
    4 replies
    Copy to Clipboard
  • Erik Nilsson

    Erik Nilsson

    11 months ago
    Hi, Is there an equivalent of Airflow’s TaskGroup’s in Prefect? Or is there any other way to build larger flows (100+ tasks) while making it easy to navigate the flow in the UI? I think I’ve seen something similar before, but I can’t find any references… Thanks
    Erik Nilsson
    Kevin Kho
    2 replies
    Copy to Clipboard