async def METHOD_NAME(self):
    dataflow = create_dataflow(
        make_zip_archive,
        {
            "input_directory_path": self.test_dir_pth,
            "output_file_path": self.test_file_pth,
        },
    )
    m_open = mock_open()
    with patch("io.open", m_open), patch(
        "zipfile.ZipFile._write_end_record"
    ):
        async for _, _ in run(dataflow):
            m_open.assert_called_once_with(self.test_file_pth, "w+b")