async def METHOD_NAME(self):
    tag = f"{USER}/{REPO}"
    before = await check_output(
        "docker",
        "ps",
        "--filter",
        f"ancestor={tag}",
        "--format",
        "{{.ID}} {{.RunningFor}}",
    )
    with mock.patch.object(
        clone_git_repo.imp, "CONTEXT", new=FakeCloneRepoImp
    ):
        async with MemoryOrchestrator.withconfig({}) as orchestrator:
            async with orchestrator(self.dataflow) as octx:
                async for ctx, results in octx.run(self.test_inputs):
                    after = await check_output(
                        "docker",
                        "ps",
                        "--filter",
                        f"ancestor={tag}",
                        "--format",
                        "{{.ID}} {{.RunningFor}}",
                    )
                    self.assertNotEqual(before, after)
                    self.assertIn("second", after)
                    self.assertIn("docker_restarted_containers", results)
                    self.containers_to_remove = results[
                        "docker_restarted_containers"
                    ]