Anna Geller
04/26/2022, 6:42 PMSlackbot
04/26/2022, 6:55 PMDylan
04/26/2022, 7:20 PMMichael Moscater
04/26/2022, 7:52 PMJosephine Douglas
04/26/2022, 11:33 PMFailed to load and execute Flow's environment: TypeError("got an unexpected keyword argument 'raise_final_state'")
What am I doing incorrectly here?Slackbot
04/27/2022, 1:32 AMRaviraja Ganta
04/27/2022, 6:28 AMFlorian Guily
04/27/2022, 10:08 AMWaiting for next available Task run at 2022-04-27T10:00:35.571259+00:00
). After a few seconds, a new log message states: Beginning Flow run for 'flow_name'
and i have all of the previous log message of the previous tasks, as if the flow was re-executed. Is it normal ? Is the flow really reexecuted ? When executing this flow from prefect cloud, i don't see those logs so i'm a bit confused.Praveen Chaudhary
04/27/2022, 10:25 AMPraveen Chaudhary
04/27/2022, 10:25 AMPraveen Chaudhary
04/27/2022, 10:25 AMSang Young Noh
04/27/2022, 11:40 AMBaris Cekic
04/27/2022, 12:30 PMKubernetesRun
. The flow is trying to download the py
file from a local git repo in the same local K8S cluster. But I got an SSL_VERIFICATION
error even though the url/host
for git storage
is HTTP
. Is there anyone having similar issue?Vivek Kaushal
04/27/2022, 12:33 PMCould not upgrade the database!
graphql_1 | Error: HTTPConnectionPool(host='hasura', port=3000): Max retries exceeded with url: /v1/query (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f25746773d0>: Failed to establish a new connection: [Errno 111] Connection refused'))
apollo_1 | Checking GraphQL service at <http://graphql:4201/health> ...
towel_1 | {"severity": "ERROR", "name": "prefect-server.Lazarus", "message": "Unexpected error: ValueError([{'extensions': {'path': '$.selectionSet.flow_run', 'code': 'validation-failed'}, 'message': 'field \"flow_run\" not found in type: \\'query_root\\''}])", "exc_info": "Traceback (most recent call last):\n File \"/prefect-server/src/prefect_server/services/loop_service.py\", line 60, in run\n await self.run_once()\n File \"/prefect-server/src/prefect_server/services/towel/lazarus.py\", line 37, in run_once\n return await self.reschedule_flow_runs()\n File \"/prefect-server/src/prefect_server/services/towel/lazarus.py\", line 89, in reschedule_flow_runs\n limit=500,\n File \"/prefect-server/src/prefect_server/database/orm.py\", line 501, in get\n as_box=not apply_schema,\n File \"/prefect-server/src/prefect_server/database/hasura.py\", line 85, in execute\n as_box=as_box,\n File \"/prefect-server/src/prefect_server/utilities/graphql.py\", line 84, in execute\n raise ValueError(result[\"errors\"])\nValueError: [{'extensions': {'path': '$.selectionSet.flow_run', 'code': 'validation-failed'}, 'message': 'field \"flow_run\" not found in type: \\'query_root\\''}]"}
Jonathan Mathews
04/27/2022, 1:24 PMSash Stasyk
04/27/2022, 1:42 PMmap
call?Marc Lipoff
04/27/2022, 1:52 PMCreating a new Dask cluster with None.fargate_cluster...
. I'm running on prefect==0.15.6. My code is attached. The trouble is that it just hangs and I have no clue what it's "trying" to do.Billy McMonagle
04/27/2022, 3:27 PMMatthew Roeschke
04/27/2022, 3:42 PMTask.map
, is there a way to customize the repr of the child task besides seeing Mapped Child n
where n is a number?
For example Task.map(x=list("abc"), ...)
, is there a way to see Mapped Child a
instead?Jonathan Mathews
04/27/2022, 3:43 PMos.environ.get
? I have also tried EnvVarSecret
but that only seems to work within a flow?Rio McMahon
04/27/2022, 4:10 PMFuETL
04/27/2022, 4:35 PMBen Fisher
04/27/2022, 4:56 PMFrederick Thomas
04/27/2022, 5:39 PMFile "/mnt/data/prefect/venv/lib/python3.8/site-packages/box/box.py", line 490, in __getattr__
raise BoxKeyError(str(err)) from None
box.exceptions.BoxKeyError: "'Config' object has no attribute 'staging_db_constring'"
However if I attempt to print out the config object the code works as expected. I haven't touched the config.toml file and Googling hasn't helped. Any help would be appreciated. ThanksAlex Cannon
04/27/2022, 5:41 PMMilly gupta
04/27/2022, 5:58 PMJai P
04/27/2022, 6:29 PMwait_for
between the subflows? i'll drop a trivial example in the threadDeepak Pilligundla
04/27/2022, 6:31 PMChris Reuter
04/27/2022, 6:45 PMMatt Delacour
04/27/2022, 7:52 PMMatt Delacour
04/27/2022, 7:52 PMKevin Kho
04/27/2022, 7:54 PMMichael Adkins
04/27/2022, 8:04 PMJulian Mehnle
04/27/2022, 8:20 PMKevin Kho
04/27/2022, 8:28 PMAnna Geller
04/27/2022, 8:46 PMflow_runner
type you attach to your DeploymentSpec
. I have a rough draft of a tutorial for AWS EC2 agent and was planning to polish it more before publishing, but given you need it now, I will share it alreadyJulian Mehnle
04/27/2022, 8:53 PMAnna Geller
04/27/2022, 8:54 PMJulian Mehnle
04/27/2022, 8:54 PMAnna Geller
04/27/2022, 9:01 PMKubernetesFlowRunner
. And for that, we already have this awesome tutorial from Laura:
https://youtu.be/bJtnx34YIYg▾
Julian Mehnle
04/27/2022, 9:04 PM