def METHOD_NAME(self, container):
    with open(os.path.join(self.working_dir, f'{container.name}.log'), 'wb') as f:
        f.write(b'Busybox output 1\n')
    docker_client = docker.from_env()
    def wait_container_start():
        for i, c in enumerate(docker_client.containers.list()):
            if c.name == container.name:
                return True
    # Ensure the container is running before checkging
    # if the input is running
    self.wait_until(
        wait_container_start,
        name="wait for test container",
        err_msg="the test container is not running yet")
    self.wait_until(lambda: self.log_contains('Starting runner: input'),
                    name="wait for input to start",
                    err_msg="did not find 'Starting runner: input' in the logs")
    self.wait_until(lambda: self.output_has(lines=1))
    output = self.read_output_json()
    # Check metadata is added
    assert output[0]['message'] == 'Busybox output 1'
    assert output[0]['container']['name'] == container.name
    assert output[0]['docker']['container']['labels'] == container.labels
    assert 'name' in output[0]['container']
    self.assert_fields_are_documented(output[0])