hey team! I'm working with prefect 1.0 and curious about triggering a flow in one tenant, when a flow in another tenant finishes successfully. I think it may be possible with a graphql query similar to this post https://stackoverflow.com/questions/68981899/create-flow-run-on-localhost-with-http-request-how-to-pass-parameters-graphql. I'm curious if anyone has any alternatives that they think are better. I'm also trying to find my graphql endpoint from these instructions https://docs-v1.prefect.io/orchestration/server/deploy-local.html#ui-configuration, but I don't see a prefect server tab, anyone know what's going on?

Hi I'm deploying prefect v1 on a VM with Ansible. I actually have a playbook to relaunch my prefect agent when needed with a kill and a launch with nohup. If my VM crash it doesn't relaunch the prefect agent as I use nohup Does someone here have ever done a linux service or a daemon to handle prefect agent ?

Hi Everyone, When I create a deployment, the deployment should be uploading all my files in my current directory to my storage (in this case, s3), however, this isn't happening on prefect 2.3.0 I've triple checked my

.prefectignore

and no, it is not ignoring anything critical. Is this a bug?

Hello, is there a documentation on how to set up prefect orion server? e.g. other than

PREFECT_API_URL

what other things need to be configured? I keep getting

[Errno -2] Name or service not known

I have prefect orion set up with helm in EKS

I am using prefect2.0. I have the following flow that I run in a docker infrastructure.

@flow
def my_flow():
    return "hola"

Using the OrionClient I am able to read the states of a flow run using

orion_client.read_flow_run_states(flow_run_id)

. The last state is

COMPLETED

and has a

data

attribute that is NOT

None

. For example the data attribute value is:

state.data = _Result(key='b1fd11041ae54cfcbb9b41ec938ff0cf', filesystem_document_id=UUID('bd1ed851-82d2-4f87-b11c-be04a80634af'))

What does this represents? Why don't I have

state.data = "hola"

instead? How do I get my flow return data from the OrionClient? Thanks a lot!

Hi everyone, I tried to set a pipenv environment in my deployment but when I ran the pipeline the environment didn't start up. Does anyone know how to fix this? Thanks!

Hey all, Prefect Live will start in 5 minutes (today at 3p Eastern). We’re hosting @Will Raphaelson, a senior tech product manager at Prefect, on PrefectLive where he’s going to show the latest improvements to deployments, in particular using Docker and Github! Come join us live on Twitch!

Hello. in Prefect1, I have a task in a flow, and I want to reuse this task in another flow 2 times with different parameters, with the second run being dependent on the fist one. Something like this:

../flow_1.py
    @task(my_task)
    def my_task(param)
.................................
from flow_1.py import my_task
../flow_2.py
    @Flow(some_flow):
        my_task(param_1)

        my_task(param_2, upstream_tasks=[my_task])

Since the 2 tasks in my Flow in flow_2 have the same name, would

upstream_tasks

work? Is there a better way to do this? Thank you

hi there! i'm trying to understand what is happening with subflows, infrastructure-wise. in particular, where they're going to be executing. more detail in thread

Hi, I’ve got a question about the REST API. The docs for the REST API say that I should be able to issue

GET /collection

to list all members of a collection, such as

GET /api/flow_runs/

. However, the server, OpenAPI spec, and example at http://localhost:4200/docs#/ say that I must supply an id to the collection, such as

GET /api/flow_runs/1234

. What the correct way to fetch the full list of collection members?

Hello, 2.0 question. For my kubernetes deployment, I've found a way to modify the flow yaml so that it will automatically delete the job pod shortly after completion. That said, it's not really scalable to manually change these every time. Is there a way to add the spec.ttlSecondsAfterFinished value via prefect cli or is that coming #soon?

In Prefect 2.0, does GitHub storage work with private Git repos? I don't really see an option to pass in creds or an api key to git

is there any change to the personal prefect UI? I cannot no longer open it:

Question, I have a simple flow that runs a single Postgres function through the SqlAlchemy module. I have orion running on a remote node, and I am running an agent locally and connecting to a test queue to try things out... I am getting multiple min delays between the flow starting and the task starting though

Hi all 👋 Quick Prefect 1 version (potentially 2.0 too, dunno yet 😄) Self-hosting with Docker, with the URL of Slack webhooks, is it possible to configure to a custom domain, rather than the default

localhost/4200

that we can’t reach without connecting to the VM etc..

Hi everybody! I’m having trouble getting the

DaskTaskRunner

working in this tutorial: https://docs.prefect.io/tutorials/execution/#parallel-execution I get a bunch of errors, e.g. “no active connection” , or “TypeError: DaskTaskRunner.submit() got an unexpected keyword argument ‘key’”

Also, I am having other (file permissions?) failures when trying to run on my deployed infrastructure rather than locally for the exact same flows mentioned above (see log in thread) I wasn't able to find anything pointing me to a resolution here... the files exist in the specified deploy location, they work in my local docker container, they don't work on this VM.

Hi All. My flow fails because a task returns "No heartbeat detected from the remote task; marking the run as failed". I used some log statements to debug, seems that the flow doesn't even start. Please suggest what I can do. Thank you.

Hi, we are randomly experiencing an issue with our prefect scheduler. Some days, some flows get submitted late. We don't see any issue with resources on the hosting servers and we don't think it is a clock issue, as other days, same flows run on schedule fine. Perhaps someone here has experienced this and has a pointer. Note: both server and agents are deployed on the same server, run out of simple python virtual environment.

Hi, I have problem with login into prefect cloud using google account. I get error 400 and status access_denied. This user can be blocked or something ? (dev@algopolis.ai)

I had done th edeployment and initital execution of jobs was successful. But no job was executed as per schedule of hourly etc. I initiated the work queue and its giving me below error Anybody can help?

I'm having some issues embedding my flow in a docker image using 2.3.0. I've been looking at the source code for a while but I'm not sure why it's not being embedded. This is what I'm running: prefect deployment build orchestration/flows/test_curated.py:default -n "Test Curated (dev)" -q "transformation-dev" -t dev -t transformation --infra docker-container --override image=my:image -o test_curated-deployment.yaml

This message was deleted.

Hi, great stuff in adding support for flows inside Docker image. It's much appreciate feature. Thanks Now a bit of feedback - my docker images are based on

python:3-9slim

and I then install all my dependencies including Prefect from a lock file. I prefer this over using the official Prefect images as it means there is a single source of truth for which version of Prefect I am using. I had my image "misconfigured" by setting working directory to

/opt/prefect/flows

. This then resulted in a cryptic message from

shutil

when running my flows as it tried to copy files from the flow source directory (

/opt/prefect/flows

by default) to a working directory (

/opt/prefect/flows

) which are the same. Would be good if Prefect detected this and did not attempt to copy the files. Or at least checked if the working directory is the same and failed with helpful error message.

Hi there, is there a possibility to see the logging messages from a task, executed by subflow in the prefect ui? e.g. is used a flow to orchestrate two flows which triggers airbyte connections in parallel and after that it triggers one dbt flow. Actually I can't see the logging from the underlaying tasts in mein prefect ui. thanks in advancd

Good question. This is something we need to update in the docs. This hot-off-the-press post shows an example for an IntervalSchedule in a Python-defined deployment. And the API docs have the specifics for the RRuleSchedule class. https://docs.prefect.io/api-ref/orion/schemas/schedules/#prefect.orion.schemas.schedules.RRuleSchedule

Please help a person in despair Hello, I'm trying to setup Prefect inside a

docker-compose

that runs on a remote VM. However, I cannot configure the correct URL for the

graphql

(when opening the UI, I get the error

Couldn't connect to Prefect Server at <http://localhost:4200/graphql>

) I tried to configure it from the

config.toml

file with the URL of my machine:

[server]
  [server.ui]
    graphql_url = "http://<<MACHINE_PUBLIC_IP>>:4200/graphql"

but it still tries the access localhost. Any help will be thoroughly appreciated. It's been 12 hours..

I got https://docs.prefect.io/api-ref/prefect/exceptions/#prefect.exceptions.ScriptError This error while running a flow through cloud UI. When I run the script using simple python flow it doesn't fail, but while running via deployment gives Script error. Prefect as documented the error but not given what might be the probable solution

Hello guys, I have few questions to ask: 1- How can I see the schematic for example with the Orion ? 2- Whe I want to see the dashboards, How Can I to change the Orion ip address to myserveraddress/4200 and not http://127.0.0.1:4200/? thank you so much

Hi all, I have a general question about Prefect 1.0 vs 2.0. Is Prefect 1.0 not going to be supported much longer? I've been working with others on a project that hasn't been deployed yet and uses Prefect 1.0, and I'm wondering if we should not be spending much effort trying to implement it using 1.0. For instance, I was interested in using control flow "case" in 1.0 but am thinking this might conflict with the new case switcher in Python 3.10, and I don't see any use of "case" in 2.0. I realize this question is kind of vague, and any advice would be appreciated!