Vlad Tudor
09/14/2022, 1:46 PMJosé Duarte
09/14/2022, 2:10 PMLeon Kozlowski
09/14/2022, 2:43 PM| ERROR | prefect.agent - Failed to submit flow run 'FLOW_RUN_ID' to infrastructure.
HTTP response body: {"kind":"Status","apiVersion":"v1","metadata":{},"status":"Failure","message":"The POST operation against Job.batch could not be completed at this time, please try again.","reason":"ServerTimeout","details":{"name":"POST","group":"batch","kind":"Job"},"code":500}
More configurations in threadBlake Hamm
09/14/2022, 3:29 PMDeployment
class (not seeing anything in the API reference). Or, if anyone else would find a .run()
method on the Deployment
class useful? 😼chris arettines
09/14/2022, 4:15 PMSam Garvis
09/14/2022, 5:17 PMKhuyen Tran
09/14/2022, 5:18 PMPedro Machado
09/14/2022, 5:20 PMKonstantinos
09/14/2022, 5:29 PMArun Giridharan
09/14/2022, 5:46 PMJason Leacox
09/14/2022, 6:07 PMkiran
09/14/2022, 7:06 PMimport psycopg2
from somewhere else instead? Running 2.3.2
Flow could not be retrieved from deployment.
Traceback (most recent call last):
File "<frozen importlib._bootstrap_external>", line 883, in exec_module
File "<frozen importlib._bootstrap>", line 241, in _call_with_frames_removed
File "/tmp/tmpcre52tf5prefect/SCRIPTNAME.py", line 3, in <module>
import psycopg2
ModuleNotFoundError: No module named 'psycopg2'
Chris Gunderson
09/14/2022, 7:45 PMAnat Tal Gagnon
09/14/2022, 7:47 PMAnat Tal Gagnon
09/14/2022, 7:50 PMAndrew Pruchinski
09/14/2022, 8:49 PMTony Piazza
09/14/2022, 8:53 PMMichael Dyer
09/14/2022, 9:23 PMLeon Kozlowski
09/14/2022, 9:24 PMKelvin Garcia
09/14/2022, 9:34 PMS3Result
? for a flow level result
I want to have something like this
bucket/jobs/{parameter}
Matt Alhonte
09/15/2022, 1:50 AMValueError: dictionary update sequence element #0 has length 1; 2 is required
Anat Tal Gagnon
09/15/2022, 3:47 AMRobin Weiß
09/15/2022, 6:37 AMEncountered exception during execution:
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 1103, in begin_task_run
return await orchestrate_task_run(
File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 1186, in orchestrate_task_run
state = await propose_state(
File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 1484, in propose_state
raise prefect.exceptions.Abort(response.details.reason)
prefect.exceptions.Abort: This run has already terminated.
This really tells me absolutely nothing, anyone have an idea maybe?
A second error that I see again and again is this one:
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/anyio/_core/_sockets.py", line 186, in connect_tcp
addr_obj = ip_address(remote_host)
File "/usr/local/lib/python3.10/ipaddress.py", line 54, in ip_address
raise ValueError(f'{address!r} does not appear to be an IPv4 or IPv6 address')
ValueError: 'api.prefect.cloud' does not appear to be an IPv4 or IPv6 address
Which again seems super cryptic to me 😅
Any hints to where I could start digging would be greatly appreciated, thanks 🙂Christian Petersen
09/15/2022, 7:56 AMprefect agent start -q 'foo'
for example, I’d like to create and apply deployments using the Deployment.build_from_flow
syntax described here https://docs.prefect.io/concepts/deployments/#create-a-deployment-from-a-python-object .
Then I want this python script to run before I start the agent…
from prefect.deployments import Deployment
from flows.deployments.example_script import flow_name
deployment = Deployment.build_from_flow(
flow=flow_name,
name="Test",
work_queue_name="test",
)
deployment.apply()
I’ve tried running it standalone and in Docker but I get a Attribute Error module 'flows.deployments.example_script.flow_name' has no attribute 'name'
If I use setattr(flow_name, 'name', 'something)'
before the definition of deployment
then I don’t get this exact error but this ValueError: Could not determine flow's file location.
I’m unsure of where to begin and would love any sort of helpVadym Dytyniak
09/15/2022, 10:48 AMasyncio.get_event_loop()
.
RuntimeError: There is no current event loop in thread 'AnyIO worker thread'.
Do you have any idea how to avoid it?Ross Teach
09/15/2022, 10:56 AMYousef Hosny
09/15/2022, 11:10 AMrun_checkpoint_validation
I get the following error but it runs fine locally.
Also, the s3 storage used to store flow code has the great_expectations directory in it..Michael Maletich
09/15/2022, 11:50 AMimport asyncio
from prefect import flow, task
@task
async def slow_task(a_value: int) -> int:
await asyncio.sleep(1)
return a_value
@flow
async def my_flow(a_value: int) -> int:
return await slow_task(a_value)
if __name__ == "__main__":
result: int = asyncio.run(my_flow(42))
print(result)
results from mypy:
test.py:13: error: Incompatible types in "await" (actual type "None", expected type "Awaitable[Any]")
test.py:17: error: Argument 1 to "run" has incompatible type "None"; expected "Coroutine[Any, Any, <nothing>]"
Any tips on making typings work with asyncio and prefectVadym Dytyniak
09/15/2022, 1:11 PMtornado
that tries to get current event loop and fails.Erik Kristiansen
09/15/2022, 1:35 PM