async def METHOD_NAME(self):
    dataflow = create_dataflow(
        extract_tar_archive,
        {
            "input_file_path": self.test_file_pth,
            "output_directory_path": self.test_dir_pth,
        },
    )
    m_open = mock_open()
    with patch("builtins.open", m_open), patch(
        "tarfile.TarFile.extractall"
    ), patch("tarfile.TarInfo.fromtarfile", m_open):
        async for _, _ in run(dataflow):
            m_open.assert_any_call("test/path/to/tar_file.tar", "rb")