async def METHOD_NAME(self):
    dataflow = create_dataflow(
        xz_decompress,
        {
            "input_file_path": self.compressed_file_pth(".xz"),
            "output_file_path": self.uncomressed_file_pth,
        },
    )
    m_open = mock_open()
    with patch("builtins.open", m_open()), patch(
        "lzma.open", m_open()
    ), patch("shutil.copyfileobj"):
        async for _, _ in run(dataflow):
            m_open.assert_has_calls(self.get_inflation_mock_calls(".xz"))