No 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")