Noah Holm
02/22/2024, 6:28 AMJef King
02/23/2024, 4:00 PMSlackbot
02/24/2024, 4:26 PMTushar Gupta
02/26/2024, 4:06 PMBrian Newman
02/26/2024, 6:55 PMPrefectHTTPStatusError: Server error '503 Service Unavailable'
Response: {'detail': 'Another process is trying to orchestrate the flow run. Please try again in a few seconds.'}
For more information check: <https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/503>
KG
02/26/2024, 8:45 PMFrancisco Sanhueza
02/27/2024, 2:42 PMKG
02/27/2024, 9:49 PMraise UnfinishedRun(
prefect.exceptions.UnfinishedRun: Run is in PENDING state, its result is not available.)
Is this intended? Is there another way of cancelling or deleting Pending flowruns without using the UINelson Griffiths
02/29/2024, 12:10 AMCormac
03/04/2024, 2:50 PMquery = f"SELECT * FROM `{table}`"
print(f"Starting DB fetch")
with conn_obj.get_engine().connect() as connection:
print(f"Got DB connection")
with connection.execution_options(yield_per=yield_per).execute(query) as result:
print("Ran DB Query")
print(f"sending block partition")
time.sleep(1)
for block in result:
p_in.send(block)
...
fails with error
AttributeError: __enter__
This type of error suggests that context manager is not supported - but it it is if SQLAlchemy is version 2.
But my pip freeze
reports prefect-sqlalchemy==0.3.2
Can someone please assist?
1. What version of SQLAlchemy is prefect-sqlalchemy built over?
2. How do I do server-side cursors with Prefect SQLAlchemy?Stephen Lloyd
03/05/2024, 7:16 AMJeff Charbeneau
03/05/2024, 7:39 PMJeff Charbeneau
03/05/2024, 7:39 PMMoxit
03/06/2024, 10:00 PMDiscovered type 'docker' for work pool 'docker-pool'.Unable to start worker. Please ensure you have the necessary dependencies installed to run your desired worker type.
I have docker running as a service and I specified it in the Requires portion of the prefect_worker.service file. Do I have to specify it anywhere else?Erling Brandvik
03/07/2024, 8:13 AMJon
03/07/2024, 7:27 PMprefect deploy --all
in our CI/CD. sometimes a few Flows will succeed to deploy to the cloud, then a deployment will fail because of something like a pydantic error and topple over our CI/CD. at that point the state of the deployments in the cloud is out of whack. is there a way to make make deployments transactional where they are all or nothing? cc @Rowdy
also, if there a way that we can mock deployments so we can test whether they succeed before we actually deploy them to our cloud instance?Moxit
03/07/2024, 11:10 PMactions-prefect-deploy@v3
. When I try to run that command locally, I have no issues with using the --prefect-file
flag. Would appreciate any assistance thank you!Bryan Dunkley
03/08/2024, 9:15 PMOmri Ildis
03/10/2024, 4:27 PMBryan
03/11/2024, 5:10 PMAmeya
03/11/2024, 6:06 PMJames Morley
03/11/2024, 7:32 PMAmy
03/11/2024, 11:43 PMDaniel Boschbach
03/12/2024, 1:24 PMextraEnvVarsSecret
https://github.com/PrefectHQ/prefect-helm/blob/main/charts/prefect-worker/values.yaml#L193
but how do I get these secrets in the flow?Hamza
03/12/2024, 1:56 PMCristian Federiconi
03/12/2024, 3:06 PMRakshith Chandrashekar
03/14/2024, 8:19 PMHristo Papazov
03/14/2024, 9:41 PMLielA
03/15/2024, 5:44 PMJason
03/17/2024, 5:15 PMlate
, and staying in there. Any things I can possibly look at?
Here is my deployment, it does deploy, but the workflow just does not execute when it should:
deployments:
- name: update-exchange-info-flow-deployment
entrypoint: exchange_sync_flow.py:update_exchange_info_flow
work_pool:
name: main-worker
job_variables:
env:
DATABASE_URL: '*******'
schedules:
- cron: '0/1 * * * *'
timezone: UTC
day_or: true
active: true
I am not sure what to check or what to do?
Thanks in advance!