• Vadym Dytyniak

    Vadym Dytyniak

    2 months ago
    Hi. We use KubernetesRun and see debug logs like this in Prefect Cloud Logs:
    Event: 'FailedScheduling' on pod 'prefect-job-79c82cd5-w6nfd'
    	Message: 0/7 nodes are available: 2 node(s) had taint {<http://dask.corp.com/component|dask.corp.com/component>: scheduler}, that the pod didn't tolerate, 5 node(s) didn't match Pod's node affinity/selector
    Do you have ideas how to disable them?
    Vadym Dytyniak
    Rob Freedy
    9 replies
    Copy to Clipboard
  • Steph Clacksman

    Steph Clacksman

    2 months ago
    I can't seem to get tasks running concurrently or in parallel with dask in prefect 2 without using task.submit() Is that expected behaviour? It doesn't seem to be reflected in the docs.
    Steph Clacksman
    Taylor Curran
    3 replies
    Copy to Clipboard
  • Tom Klein

    Tom Klein

    2 months ago
    Hello 🙋 is there a default limit for concurrent flows or something in the Cloud? we have currently a flow that was run ad-hoc and is still running, and a flow that was scheduled to run now, and it’s stuck in
    Submitted
    and nothing seems to be happening with it
    Tom Klein
    Mason Menges
    6 replies
    Copy to Clipboard
  • d

    David

    2 months ago
    Hi all, I am trying to run a flow with VertexRun. I created a GitLab repo, configured the Gitlab storage. Run a agent locally with vertex and the prefect cloud api key. However on run I keep getting the same error. Failed to load and execute flow run: ModuleNotFoundError. It keeps refering to a local path.
    d
    1 replies
    Copy to Clipboard
  • d

    David

    2 months ago
    Why do I keep seeing this error while I am using the gitlab storage...
  • Rajvir Jhawar

    Rajvir Jhawar

    2 months ago
    Hi prefect team, I had a question about deployment pausing in prefect 2.0. I am little confused by this concept. If a work queue is filtering by deployment and the deployment is paused do all flow runs based on said deployment get paused and go into a "pending" state? I don't see a way "pause" deployment programatically via either the cli or the api. It seems like this is a UI only feature am i missing something here?
    Rajvir Jhawar
    2 replies
    Copy to Clipboard
  • Prass

    Prass

    2 months ago
    Shameless plug: I made a meta-package linking different packages for different use cases. https://github.com/prassanna-ravishankar/python-productivity-stack Under the
    mlops
    section, I've added prefect -
    pip install productivity-stack[mlops]
    Prass
    Anna Geller
    2 replies
    Copy to Clipboard
  • Chu

    Chu

    2 months ago
    Hi, anyone knows how can I send params which contain mapped and unmapped parameters to create_flow_run? (More in the thread)
    Chu
    Anna Geller
    +1
    33 replies
    Copy to Clipboard
  • a

    Andrew Pruchinski

    2 months ago
    Hey all. Our flow isn't able to spin up more than 180 jobs. We can't determine the root cause exactly but at a certain point there's a connection aborted and prefect starts to remove jobs and then marks the entire flow as failed. We are using a daskexecutor on the cloud. Looking into the dask repos, we aren't able to set some debug level logging as an attempt to retrieve some info on what’s really causing the
    Connection aborted
    issue. Even if there are some failures, we do want the flow to continue and the task triggers are set accordingly. Thank you
    a
    Bianca Hoch
    19 replies
    Copy to Clipboard
  • Leon Kozlowski

    Leon Kozlowski

    2 months ago
    Hi all, does anyone have experience integrating prefect alerts/failures with opsgenie?
    Leon Kozlowski
    1 replies
    Copy to Clipboard