Samuel Bunce
02/27/2023, 10:15 AMredsquare
02/27/2023, 5:38 PMJohn Mizerany
02/27/2023, 10:02 PM403 forbidden
when it filters for an event in the UILennart
02/28/2023, 11:29 AMpath=os.getcwd() + "/flows
and
entrypoint="flow.py:test_flow
The test flow runs the following command:
shell_run_command(
command="python3 src/task.py", return_all=True
)
The project structure is as follows:
project
- flows
-- depolyments.py
-- flow.py
- src
-- task.py
I run the task runner from the project root with prefect agent start -p default-agent-pool
I applied the deployments and see them in the cloud and can start them from there.
The error I get is: can't open file /tmp/tmp6ohfe_wcprefect/src/task.py [Errno 2] No such file or directory
After exiting the process not even /tmp/tmp6ohfe_wcprefect
exists, but I dont know if this is because prefect tears it down.
Any help regarding this would be very appreciated. I hope i provided enough information to help with this. If not, let me know.Nicolas Garcia Ospina
02/28/2023, 1:22 PMMurmuration Dev
03/01/2023, 10:47 AMTaylor Babin
03/03/2023, 4:21 PMDejapong Lsuwaratana
03/06/2023, 5:34 PM/deployments/deployment/<uuid>
route in the UI). I’ve included a screenshot, my parameters are really simple, just a single level Pydantic (v 1.10.4) object with some floats. Do you have any advice on how I could debug this?iñigo
03/06/2023, 5:35 PMiñigo
03/06/2023, 5:36 PMAmruth VVKP
03/06/2023, 8:21 PM2023-03-06 20:19:39 value = await result
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/connection.py", line 2092, in connect
2023-03-06 20:19:39 return await connect_utils._connect(
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/connect_utils.py", line 895, in _connect
2023-03-06 20:19:39 raise last_error
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/connect_utils.py", line 881, in _connect
2023-03-06 20:19:39 return await _connect_addr(
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/connect_utils.py", line 773, in _connect_addr
2023-03-06 20:19:39 return await __connect_addr(params, timeout, True, *args)
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/connect_utils.py", line 825, in __connect_addr
2023-03-06 20:19:39 tr, pr = await compat.wait_for(connector, timeout=timeout)
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/compat.py", line 56, in wait_for
2023-03-06 20:19:39 return await asyncio.wait_for(fut, timeout)
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/asyncio/tasks.py", line 445, in wait_for
2023-03-06 20:19:39 return fut.result()
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/site-packages/asyncpg/connect_utils.py", line 684, in _create_ssl_connection
2023-03-06 20:19:39 tr, pr = await loop.create_connection(
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/asyncio/base_events.py", line 1036, in create_connection
2023-03-06 20:19:39 infos = await self._ensure_resolved(
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/asyncio/base_events.py", line 1418, in _ensure_resolved
2023-03-06 20:19:39 return await loop.getaddrinfo(host, port, family=family, type=type,
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/asyncio/base_events.py", line 863, in getaddrinfo
2023-03-06 20:19:39 return await self.run_in_executor(
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/concurrent/futures/thread.py", line 58, in run
2023-03-06 20:19:39 result = self.fn(*self.args, **self.kwargs)
2023-03-06 20:19:39 File "/usr/local/lib/python3.10/socket.py", line 955, in getaddrinfo
2023-03-06 20:19:39 for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
2023-03-06 20:19:39 socket.gaierror: [Errno -2] Name or service not known
2023-03-06 20:19:39
2023-03-06 20:19:39 Application startup failed. Exiting.
Here's my docker-compose -
version: '3.8'
networks:
prefect:
name: prefect
services:
# ------------------------------------------------------------- #
# PostgreSQL DB for Prefect DB #
# ------------------------------------------------------------- #
postgres:
image: postgres:latest
restart: always
command:
- postgres
- -c
- max_connections=150
environment:
- POSTGRES_USER=${POSTGRES_USER}
- POSTGRES_PASSWORD=${POSTGRES_PASSWORD}
- POSTGRES_DB=${POSTGRES_DB}
healthcheck:
interval: 10s
retries: 60
start_period: 2s
test: pg_isready -q -d $${POSTGRES_DB} -U $${POSTGRES_USER} | grep "accepting connections" || exit 1
timeout: 2s
ports:
- 5432:5432
expose:
- 5432
# -------------------------------------- #
# Prefect Server #
# -------------------------------------- #
prefect-server:
image: prefecthq/prefect:2.8.4-python3.10
command:
- prefect
- server
- start
ports:
- 4200:4200
expose:
- 4200
environment:
PREFECT_API_DATABASE_CONNECTION_URL: postgresql+asyncpg://${POSTGRES_USER}:${POSTGRES_PASSWORD}@postgres:5432/${POSTGRES_DB}
networks:
- prefect
restart: always
depends_on:
postgres:
condition: service_started
Jenny
03/08/2023, 7:42 PMDavid Steiner Sand
03/09/2023, 8:27 PMAwaitingRetry
state available as a filter in the UI, could it be added there? (I haven’t found any issue related to this topic).
Also, queues are not set as unhealthy
when there are flow runs AwaitingRetry
, I’m not sure this is the desired behavior…redsquare
03/17/2023, 1:23 PMBrandon Reid
03/17/2023, 6:14 PMMichał Augoff
03/17/2023, 6:37 PMMichał Augoff
03/17/2023, 6:39 PMscott
03/20/2023, 4:38 PMSerina
03/20/2023, 8:12 PMPaco Ibañez
03/21/2023, 4:56 PMManoj
03/25/2023, 8:26 PMYSF
03/27/2023, 1:29 AMSlackbot
03/29/2023, 7:16 AMMarilyn Bass
03/31/2023, 7:52 PMJean-Michel Provencher
04/03/2023, 11:46 AMFilip Panovski
04/06/2023, 3:49 PMBrandon Reid
04/07/2023, 1:24 PMmy-flow / raging-platypus
)Alex Shea
04/10/2023, 2:02 PMsjammula
04/13/2023, 11:22 PMAndreas Nord
04/14/2023, 12:56 PM