Panda
08/30/2023, 10:30 PMOscar Montanes
08/30/2023, 10:51 PMTraceback (most recent call last):
File "/Library/Frameworks/Python.framework/Versions/3.10/bin/prefect", line 5, in <module>
from prefect.cli import app
File "/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/site-packages/prefect/_init_.py", line 45, in <module>
from prefect.engine import pause_flow_run, resume_flow_run
File "/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/site-packages/prefect/engine.py", line 98, in <module>
from anyio import start_blocking_portal
ImportError: cannot import name 'start_blocking_portal' from 'anyio' (/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/site-packages/anyio/_init_.py)
Stampeder
08/31/2023, 3:10 PMStampeder
08/31/2023, 3:12 PMStampeder
08/31/2023, 3:12 PMEric
09/01/2023, 11:27 PMif __name__ == "__main__":
deployment: Deployment = Deployment.build_from_flow(
flow=test_flow,
name="example",
version="1",
tags=["demo"],
work_pool_name='local_agent_work_pool'
)
deployment.apply()
I confirmed that the deployment worked in the Prefect Cloud UI.
In my flask endpoint, I am trying to submit the flow run to Prefect cloud like so, but it feels wrong:
@flask_route.route("/prefect", methods=['POST'])
def start_prefect_flow():
# prefect_client = get_client(
# # api_key='redacted'
# )
prefect_client = PrefectClient(
api='redacted',
api_key='redacted'
)
res = prefect_client.create_flow_run(test_flow)
print(res)
First, I don't think I should be creating the client this way, but unsure how else I should be passing my api/api key information to it. This is also returning a coroutine object instead of what I thought would be information about my flow run, but maybe that makes sense since I don't see a flow run being kicked off. Some assistance here would be super helpful!Stampeder
09/03/2023, 11:31 AMJoe D
09/05/2023, 5:43 PMKeyError: "No class found for dispatch key 'ecs-task' in registry for type 'Block'."
If I run pip3 install prefect-aws
on my instance I get this dependency conflict:
ERROR: pip's dependency resolver does not currently take into account all the packages that are installed. This behaviour is the source of the following dependency conflicts.
aiobotocore 2.5.4 requires botocore<1.31.18,>=1.31.17, but you have botocore 1.31.40 which is incompatible.
And when I launch my flow I get the same KeyError along with:
Warning! Failed to load collection 'prefect_aws': AttributeError: module 'lib' has no attribute 'OpenSSL_add_all_algorithms'
17:32:19.694 | ERROR | prefect.agent - Failed to get infrastructure for flow run '96a4ce05-7431-4062-bb2b-8c039d5d77e0'.
Are there versions of prefect2 / prefect-aws I can use to get this to work? Am I missing something obvious / should I rethink my execution layer?Nicola Pancotti
09/08/2023, 11:05 PMEric
09/09/2023, 12:29 AMEric
09/11/2023, 6:30 PMYoni
09/12/2023, 2:27 PMGustavo Zuniga Goni
09/13/2023, 2:04 AMnavya magisetty
09/13/2023, 9:19 AMJimmy
09/13/2023, 1:55 PMDaniel
09/13/2023, 2:47 PMSlackbot
09/13/2023, 3:15 PMAndy Warren
09/14/2023, 7:42 PMerenwu
09/15/2023, 7:42 AMNimesh Kumar
09/15/2023, 11:17 AMMorten Hauge
09/16/2023, 8:23 AMLior Barak
09/18/2023, 2:18 PMJake
09/18/2023, 4:18 PMAlex Shtuchkin
09/18/2023, 7:15 PMsqlboi
09/19/2023, 2:19 PMprefect.yaml
file is?
i have a scenario where this file will get recreated each time a container gets spun up - but i also want to run it with volumes. and i dont want each container replacing the other's fileTanmay Madan
09/19/2023, 4:17 PMTuan Dang
09/20/2023, 4:31 AMManoj Ravi
09/20/2023, 5:11 AMDhiraj
09/20/2023, 1:33 PMFailed to submit flow run '***' to infrastructure.
Traceback (most recent call last):
File "/usr/local/lib/python3.11/site-packages/urllib3/util/ssl_.py", line 402, in ssl_wrap_socket
context.load_verify_locations(ca_certs, ca_cert_dir, ca_cert_data)
ssl.SSLError: [X509: NO_CERTIFICATE_OR_CRL_FOUND] no certificate or crl found (_ssl.c:4154)
Sarika
09/23/2023, 4:19 PM