Searched refs:_GCSCleanupPipeline (Results 1 – 2 of 2) sorted by relevance
53 CleanupPipeline = shuffler._GCSCleanupPipeline
706 yield _GCSCleanupPipeline(all_temp_files)711 class _GCSCleanupPipeline(pipeline_base.PipelineBase): class