Samay Kapadia
01/17/2022, 10:46 PMNo module named '/Users/sa/'
. Why does it want my home directory to be a module? More details insideNo module named '/Users/sa/'
Traceback (most recent call last):
File "/usr/local/bin/prefect", line 8, in <module>
sys.exit(cli())
File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1128, in __call__
return self.main(*args, **kwargs)
File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1053, in main
rv = self.invoke(ctx)
File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1659, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1659, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/usr/local/lib/python3.7/site-packages/click/core.py", line 1395, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/usr/local/lib/python3.7/site-packages/click/core.py", line 754, in invoke
return __callback(*args, **kwargs)
File "/usr/local/lib/python3.7/site-packages/prefect/cli/execute.py", line 96, in flow_run
raise exc
File "/usr/local/lib/python3.7/site-packages/prefect/cli/execute.py", line 73, in flow_run
flow = storage.get_flow(flow_data.name)
File "/usr/local/lib/python3.7/site-packages/prefect/storage/local.py", line 103, in get_flow
module_str=flow_location, flow_name=flow_name
from prefect import Flow
from prefect.run_configs import KubernetesRun
from prefect.tasks.kubernetes.job import RunNamespacedJob
JOB_NAME = "dummy"
body = {
"apiVersion": "batch/v1",
"kind": "Job",
"metadata": {"name": JOB_NAME},
"spec": {
"template": {
"spec": {
"containers": [
{
"name": "echo",
"image": "alpine:3.7",
"command": ["echo", "Hello"],
}
],
"restartPolicy": "Never",
}
},
"backoffLimit": 4,
},
}
k8s_run_config = KubernetesRun()
create_and_run_job = RunNamespacedJob(body=body)
with Flow("hello-flow", run_config=k8s_run_config) as flow:
create_and_run_job()
flow.register("main")
Kevin Kho
Samay Kapadia
01/17/2022, 10:48 PM