@Marvin How to Clean the prefect salute DB data ?

@Marvin why am I getting TypeError: ‘NoneType’ object is not iterable when using the command

prefect deployment run

hi everyone! im facing a weird issue in flow runs . im running prefect on aws eks ( self hosted instance of orion and kubernetes jobs on different namespaces ) 1. i have 9 running flows which i can see on the ui but i cant find the corresponding job on my cluster 2. when i check the concurrency-limit for the tags that these flow use i can see 14 task runs ( these flow have parallel task runs so some of them are having more than one task stuck in running state) so basically 9 running flows with 14 running tasks as i can see on the ui but i cant find the jobs on my cluster. doubt - how did these flow runs get terminated on the cluster and even if they did why did it not update in the ui or lets say why was the state not updated in meta db attaching screenshots for the same

Hi everyone quite new to prefect and testing something out but I’m stuck,. I want to use

Deployment.build_from_flow

, it works when I put this in the same directory of the

flows

But what I want is the following:

- deployments:
   -- deployments.py (file with all my deployments)
- flows:
   -- flow_a.py
   -- flow_b.py

When I generate the deployments I get:

ValueError: '..../updates/flows/flow_a.py' is not in the subpath of '.../updates/deployments' OR one path is relative and the other is absolute.

It has to do with this line

entry_path = Path(flow_file).absolute().relative_to(Path(".").absolute())

-> it does not look like I can edit this “path” Anyone has done this before? Is this even possible?

Hello 🙂 I believe I ran into a threading problem yesterday. I am converting some data extraction pipelines to prefect 2 flows, which works fine for most of them. I just add the decorators and some logging. But one of the data pipelines uses sqlite for intermediate storage, and this is the error message I receive:

sqlite3.ProgrammingError: SQLite objects created in a thread can only be used in that same thread. The object was created in thread id 140193261803264 and this is thread id 140192735962880.

I can also paste the part of the code where sqlite is called. I am also trying to guess the reason behind the error. There is an sqlite object created in a function. Within the function I define another function which uses this object. But both python functions are not prefect flows or tasks. They live within a bigger prefect flow. So here comes my first question: Does prefect 2 create a different thread for each nested function inside a flow or a task. Otherwise I cannot explain why the 2 parts of the code would run in different threads.

Hello folks, I am trying to run Prefect server on an EC2 instance using the instructions in Prefect Docs and am facing the following error while trying to get it up and running. Has anyone faced a similar issue in hosting Prefect server?

Could 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\\''}]"}

@Marvin ValueError: Unable to find block document named “” for block type s3:

Hello! Can anyone recommend how to provision a Prefect Block which supports connecting to AWS Redshift? using standard postgres

POSTGRESQL_PSYCOPG2

results in a driver which throws the following error on connection:

sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedObject) unrecognized configuration parameter "standard_conforming_strings"

This is, apparantly, a known issue: https://github.com/sqlalchemy/sqlalchemy/issues/9442 More worryingly, I cannot see any support in Prefect connectors for Redshift. Can anyone advise?

@Marvin I have prefect 3 and pydantic 2.8 I am getting this error File "/home/ubuntu/cleargrid-dwt-prefect/dwhenv/lib/python3.12/site-packages/pydantic/_internal/_generate_schema.py", line 2227, in _extract_get_pydantic_json_schema raise PydanticUserError( pydantic.errors.PydanticUserError: The

__modify_schema__

method is not supported in Pydantic v2. Use

__get_pydantic_json_schema__

instead in class

SecretStr

.

Does prefect have a drag-and-drop-based UI,? I want to use it for network operators. They can’t code.