Tomas Moreno
08/31/2022, 4:16 PMElio
08/31/2022, 4:18 PMhttps://puu.sh/Jj0Q7/77bd248705.png▾
Blake Stefansen
08/31/2022, 4:32 PM.prefectignore
and no, it is not ignoring anything critical. Is this a bug?Mia
08/31/2022, 5:57 PMPREFECT_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 EKSMarc-Antoine Bélanger
08/31/2022, 6:31 PM@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!Luis Diaz
08/31/2022, 6:54 PMKhuyen Tran
08/31/2022, 6:54 PMMansour Zayer
08/31/2022, 7:05 PM../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 youJai P
08/31/2022, 7:07 PMMars
08/31/2022, 8:08 PMGET /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?Emerson Franks
08/31/2022, 8:39 PMSam Garvis
08/31/2022, 8:55 PMTony Yun
08/31/2022, 9:57 PMAdam Brusselback
08/31/2022, 10:08 PMJovan Sakovic
08/31/2022, 11:13 PMlocalhost/4200
that we can’t reach without connecting to the VM etc..Matt Fysh
09/01/2022, 1:03 AMDaskTaskRunner
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’”Adam Brusselback
09/01/2022, 1:45 AMArchitha Rao
09/01/2022, 6:52 AMKonstantinos
09/01/2022, 7:17 AMRobert Kowalski
09/01/2022, 7:36 AMPranit
09/01/2022, 12:12 PMOscar Björhn
09/01/2022, 12:15 PMSlackbot
09/01/2022, 12:32 PMDavid Hlavaty
09/01/2022, 12:33 PMpython: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.Dennis Hinnenkamp
09/01/2022, 1:53 PMJeff Hale
09/01/2022, 2:04 PMVlad Tudor
09/01/2022, 2:09 PMdocker-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..Pranit
09/01/2022, 2:09 PMYoussef Ben Farhat
09/01/2022, 2:42 PMAlexander Kloumann
09/01/2022, 2:53 PM