redshift_sql_to_avsc_test.py 文件源码

def test_run_converts_existing_if_overwrite_true(
            self,
            sql_file_path,
            avsc_file_path,
            globs,
            mock_get_file_paths_from_glob_patterns,
            mock_os_path_exists,
            mock_batch
    ):
        mock_batch.options.overwrite = True
        mock_batch.run()
        assert mock_get_file_paths_from_glob_patterns.mock_calls == [
            mock.call(glob_patterns=globs)
        ]
        assert mock_os_path_exists.mock_calls == [mock.call(avsc_file_path)]
        assert mock_batch.convert_sql_to_avsc.mock_calls == [
            mock.call(
                avsc_file_path=avsc_file_path,
                sql_file_path=sql_file_path
            )
        ]