Getting a surprising-to-me error running a super-simple flow using the "Non-Docker Storage for Containerized Environments" recipe - something that was working in 12.x. If I start my agent with

--show-flow-logs

and try to run the registered flow via the UI. Agent picks up the job fine but reports:

[2020-08-06 23:43:16,058] ERROR - agent | Error while deploying flow: AttributeError("Can't pickle local object 'NpipeHTTPAdapter.__init__.<locals>.<lambda>'")
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "C:\Python38\lib\multiprocessing\spawn.py", line 116, in spawn_main
    exitcode = _main(fd, parent_sentinel)
  File "C:\Python38\lib\multiprocessing\spawn.py", line 126, in _main
    self = reduction.pickle.load(from_parent)
EOFError: Ran out of input

Hi @Skip Breidbach - not sure what might be going on here, can you provide a min reproducible example for us to take a look at?

@nicholas sure thing! Sorry for the delay. Here's a bare-bones example.

from prefect import Flow, task
from prefect.environments import LocalEnvironment
from prefect.environments.storage import S3, Docker


@task
def do_it():
    return 1

storage = Docker(
    image_name="simple-container",
    image_tag='latest',
    base_image='prefecthq/prefect:all_extras-0.13.1',
)

storage.build()

with Flow("simple",
          storage=S3(bucket="skip-sandbox", key="flows/simple"),
          environment=LocalEnvironment(metadata={"image": "simple-container"})) as flow:
    x = do_it()

flow.register(project_name="Skip's Sandbox")

Thanks @Skip Breidbach, I'm going to open an issue for the Core team to take a look at this behavior.

Hey @Skip Breidbach I posted a comment on that issue 🙂