Oscar Krantz
06/22/2022, 2:15 PMAmit Gupta
06/22/2022, 3:58 PMrectalogic
06/22/2022, 4:45 PMMichał Augoff
06/22/2022, 5:32 PMget_task_run_result
to fetch task results from a different flow. The result location is correct but the serializer defaults to Pickle while that task uses PandasSerializer, so it errors out with PickleRobert Spurrier
06/22/2022, 5:36 PMaudit_log
returns this information in the message
field, but looks to only be for the current tenant only. Wondering if there is a way to get this across all tenants/users associated with a licenserectalogic
06/22/2022, 5:51 PMPaco Ibañez
06/22/2022, 6:45 PMpython -m prefect.engine <flow_run_id>
but I get This run has already terminated
Danilo Drobac
06/22/2022, 6:46 PMAlex Tam
06/22/2022, 8:17 PMbotocore.exceptions.ClientError: An error occurred (AccessDenied) when calling the PutObject operation: Access Denied
Tilé
06/22/2022, 8:33 PMmap
for each item. On the UI it says "No heartbeat detected from the remote task; marking the run as failed.", but the result of the workflow is marked as "Success". I checked my database and everything looks like the task succeeded. Any idea what is going on and how can I avoid it?
Have a nice day!Bob Colner
06/22/2022, 8:34 PMMichael Duncan
06/22/2022, 9:57 PMstate.result
from the flow which works locally but not in the cloud explained in this answer https://prefect-community.slack.com/archives/CL09KU1K7/p1653606914417649.
Is there a good way to collect exceptions from each task and report them in a state handler when the flow fails? We have have alerts on flow failures and we want to report the exceptions in the alertAbin Antony
06/22/2022, 10:09 PMAbin Antony
06/22/2022, 10:20 PMKen Nguyen
06/23/2022, 12:52 AMis_cancelled()
when looking here.Amol Shirke
06/23/2022, 2:06 AMyu zeng
06/23/2022, 3:44 AMluke b
06/23/2022, 5:57 AMDanilo Drobac
06/23/2022, 8:49 AMlocalhost:8000
.
I'm trying to connect to the instance (to make an API call) through a Python script, but I have no idea how to think about the authentication layer.
How do I send an API call to the server? The documentation suggests not to open the instance up to HTTP traffic but I'm guessing that's a requirement to be able to communicate with the API?Raviraja Ganta
06/23/2022, 9:58 AMsuccess_task
that will send a SQS message to my backend server indicating that the flow ran successfully. Now, I want to send a message when there is a failure in execution of task as well. Since the amount of tasks can be high (more than 10), is there a better to do error handling of the tasks?Dominik Wagner
06/23/2022, 10:21 AM2.0b7
and noticed that prefect orion kubernetes-manifest
is not a valid command. I assume I can just use the manifest from 2.0b6 and change the image version - so this is more of an FYI, since it’s still in the docs. Or is there something else I should be aware of here?Surya
06/23/2022, 10:58 AMJoshua Greenhalgh
06/23/2022, 11:01 AMZheng Cheng
06/23/2022, 11:51 AMZheng Cheng
06/23/2022, 12:34 PMjack
06/23/2022, 1:31 PMproject/
flow.py
scripts/
util.py
And in flow.py, there is this import statement:
from scripts.util import Util
Also in flow.py, using this storage:
with Flow('some-name', storage=S3(bucket='some-bucket')):
...
But when run from the cloud, it complains No module named "scripts.util"
redsquare
06/23/2022, 1:38 PMStéphanie Cérulli
06/23/2022, 2:00 PMStéphanie Cérulli
06/23/2022, 2:00 PMMichal Zawadzki
06/23/2022, 2:24 PMprefecthq/prefect:2.0b7-python3.10
to be exact); I was getting error code 255 at the apt-key add
step in my custom image. Adding `apt install gnupg`fixed the issue.Michal Zawadzki
06/23/2022, 2:24 PMprefecthq/prefect:2.0b7-python3.10
to be exact); I was getting error code 255 at the apt-key add
step in my custom image. Adding `apt install gnupg`fixed the issue.Kevin Kho
06/23/2022, 2:44 PMMarvin
06/23/2022, 2:45 PM