Milou Van Cau
12/10/2022, 8:16 PM<http://DATA_FULL.to|DATA_FULL.to>_csv("csv_files/DATA_FULL.csv")
But when i run it without prefect it works fine.
does anyone has an idea of what i have to change ?Nils
12/11/2022, 6:50 PM18:41:58.602 | INFO | prefect.agent - Submitting flow run '5b4470d3-8cd0-4073-8c03-be70eac1deff'
18:41:59.077 | INFO | prefect.infrastructure.docker-container - Pulling image URL...
18:41:59.722 | INFO | prefect.infrastructure.docker-container - Creating Docker container 'invaluable-hyena'...
18:41:59.743 | INFO | prefect.infrastructure.docker-container - Docker container 'invaluable-hyena' has status 'created'
18:42:00.303 | INFO | prefect.agent - Completed submission of flow run '5b4470d3-8cd0-4073-8c03-be70eac1deff'
18:42:00.307 | INFO | prefect.infrastructure.docker-container - Docker container 'invaluable-hyena' has status 'running'
18:42:02.695 | INFO | prefect.infrastructure.docker-container - Docker container 'invaluable-hyena' has status 'exited'
18:42:02.697 | INFO | prefect.infrastructure.docker-container - Docker container 'invaluable-hyena' has status 'exited'
Traceback from the container:
Flow could not be retrieved from deployment.
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/engine.py", line 260, in retrieve_flow_then_begin_flow_run
flow = await load_flow_from_flow_run(flow_run, client=client)
File "/usr/local/lib/python3.8/site-packages/prefect/client/utilities.py", line 47, in with_injected_client
return await fn(*args, **kwargs)
File "/usr/local/lib/python3.8/site-packages/prefect/deployments.py", line 167, in load_flow_from_flow_run
await storage_block.get_directory(from_path=deployment.path, local_path=".")
File "/usr/local/lib/python3.8/site-packages/prefect/filesystems.py", line 908, in get_directory
process = await run_process(cmd, stream_output=(out_stream, err_stream))
File "/usr/local/lib/python3.8/site-packages/prefect/utilities/processutils.py", line 73, in run_process
async with open_process(
File "/usr/local/lib/python3.8/contextlib.py", line 171, in __aenter__
return await self.gen.__anext__()
File "/usr/local/lib/python3.8/site-packages/prefect/utilities/processutils.py", line 35, in open_process
process = await anyio.open_process(command, **kwargs)
File "/usr/local/lib/python3.8/site-packages/anyio/_core/_subprocesses.py", line 127, in open_process
return await get_asynclib().open_process(
File "/usr/local/lib/python3.8/site-packages/anyio/_backends/_asyncio.py", line 1105, in open_process
process = await asyncio.create_subprocess_exec(
File "/usr/local/lib/python3.8/asyncio/subprocess.py", line 236, in create_subprocess_exec
transport, protocol = await loop.subprocess_exec(
File "/usr/local/lib/python3.8/asyncio/base_events.py", line 1630, in subprocess_exec
transport = await self._make_subprocess_transport(
File "/usr/local/lib/python3.8/asyncio/unix_events.py", line 197, in _make_subprocess_transport
transp = _UnixSubprocessTransport(self, protocol, args, shell,
File "/usr/local/lib/python3.8/asyncio/base_subprocess.py", line 36, in __init__
self._start(args=args, shell=shell, stdin=stdin, stdout=stdout,
File "/usr/local/lib/python3.8/asyncio/unix_events.py", line 789, in _start
self._proc = subprocess.Popen(
File "/usr/local/lib/python3.8/subprocess.py", line 858, in __init__
self._execute_child(args, executable, preexec_fn, close_fds,
File "/usr/local/lib/python3.8/subprocess.py", line 1704, in _execute_child
raise child_exception_type(errno_num, err_msg, err_filename)
FileNotFoundError: [Errno 2] No such file or directory: 'git'
Suram R
12/12/2022, 4:37 PMSebastian Steele
12/12/2022, 6:25 PMTony
12/14/2022, 5:43 PMVio
12/14/2022, 6:49 PMWingmore
12/15/2022, 4:26 AMPraveen Shilavantar
12/19/2022, 9:38 PMclass API:
@flow
def start(self):
pass
I am getting TypeError: missing a required argument: 'self'Michael Dymshits
12/20/2022, 12:40 PMpytest
which has perfect decorator
,
I got the following error (screenshot bellow).
If I use comment #flow decorator, pytest runs without errors.Michael Dymshits
12/20/2022, 12:42 PMMichael Dymshits
12/20/2022, 12:43 PMMatt Morris
12/22/2022, 4:41 PMtask
decorator should be above function definition), but not sure which issue template to use. Bug template seems like overkill...help?Laraib Siddiqui
12/22/2022, 5:50 PMfrom prefect.tasks.shell import ShellTask
it throws out and error
ModuleNotFoundError: No module named 'prefect.tasks.shell'; 'prefect.tasks' is not a package
I know i can use prefect-shell
to overcome this and run python scripts but i couldn't find any resolution on the above errorLaraib Siddiqui
12/22/2022, 5:56 PMprefect orion start --port 8000
My port is open to communicate with the host.Laraib Siddiqui
12/23/2022, 5:02 AMLaraib Siddiqui
12/24/2022, 10:53 PMRyan Peden
12/24/2022, 11:08 PM--apply
to your build command, or run prefect deployment apply
on the YAML file generated by the build command.Hanyang Tan
12/27/2022, 3:21 AMhttpx.HTTPStatusError: Server error '500 Internal Server Error' for url '<http://127.0.0.1:4200/api/flow_runs/>'
all the way. I got no idea why is this happening, is any one encounter this before?Hanyang Tan
12/27/2022, 3:29 AMhttpx.HTTPStatusError: Server error '500 Internal Server Error' for url '<http://127.0.0.1:4200/api/flow_runs/>'
all the way. I got no idea why is this happening, is any one encounter this before? Below are my steps and some snapshot of Prefect version, command prompt that executed the code and the code itself.
Here is my steps to get this error:
1. Create python virtual environment using this command python -m venv prefect
2. Activated the prefect
environment
3. Install Prefect pip3 install -U prefect
4. Start the Prefect Orion Server prefect orion start
5. Write a sample python code and execute the code python test.py
6. Error happened.Cole
12/27/2022, 11:05 PM| __ \| __ \| ____| ____| ____/ ____|__ __|
| |__) | |__) | |__ | |__ | |__ | | | |
| ___/| _ /| __| | __| | __|| | | |
| | | | \ \| |____| | | |___| |____ | |
|_| |_| \_\______|_| |______\_____| |_|
Thanks for using Prefect!!!
This is the official docker image for Prefect Core, intended for executing
Prefect Flows. For more information, please see the docs:
<https://docs.prefect.io/core/getting_started/quick-start.html>
Anyone have any idea of what I'm doing wrong? Should I be starting with prefect server instead?Rohit Motiani
12/28/2022, 5:20 PMar
12/29/2022, 6:24 AMLaraib Siddiqui
12/30/2022, 5:54 PMThet Naing
12/31/2022, 6:56 PMThet Naing
12/31/2022, 6:57 PM.map
to run a task on each batch of 50 documents. It appears that when I use .map
, it is running all of the tasks within a single GCP Cloud Run Job. I was wondering, is it possible to configure Prefect to spin up new Cloud Run Jobs for each of these mapped tasks? Thanks in advance for any help!Benoît Linsey-Fazi
01/02/2023, 5:43 PMGreg Kennedy
01/05/2023, 5:10 AMquassy
01/06/2023, 11:29 AMMario Vormstein
01/09/2023, 3:58 PM