diff --git a/pipelines/_ingredients/Conversions.yaml b/pipelines/_ingredients/Conversions.yaml index 1d3adf1..649fbb1 100644 --- a/pipelines/_ingredients/Conversions.yaml +++ b/pipelines/_ingredients/Conversions.yaml @@ -12,16 +12,6 @@ tasks: # This is output directly by CalibrateImageTask. connections.inputCatalogs: single_visit_star_unstandardized connections.outputCatalog: initial_stars - - # Merging of *Diff_diaSrcTable [detector-level Parquet] to dia_source_visit [visit-level] - consolidateDiaSourceTable: - class: lsst.pipe.tasks.postprocess.ConsolidateSourceTableTask - config: - # Task doesn't support coaddName, so coopt catalogType instead. - connections.catalogType: parameters.coaddName - connections.inputCatalogs: dia_source_detector - connections.outputCatalog: dia_source_visit - makeVisitTable: class: lsst.pipe.tasks.postprocess.MakeVisitTableTask config: diff --git a/pipelines/_ingredients/ConversionsForFakes.yaml b/pipelines/_ingredients/ConversionsForFakes.yaml index 5298769..b2b4b3c 100644 --- a/pipelines/_ingredients/ConversionsForFakes.yaml +++ b/pipelines/_ingredients/ConversionsForFakes.yaml @@ -7,9 +7,6 @@ description: Type conversion tasks customized for AP pipeline imports: - location: $AP_VERIFY_DIR/pipelines/_ingredients/Conversions.yaml - exclude: - # Fakes pipeline doesn't produce non-fakes dia_source_visit. - - consolidateDiaSourceTable tasks: # TODO: TransformSourceTableTask can't be run until we create a functor # config that doesn't depend on shapeHSM. @@ -20,12 +17,6 @@ tasks: # This is output directly by CalibrateImageTask. connections.inputCatalogs: single_visit_star_unstandardized connections.outputCatalog: consolidated_single_visit_star_unstandardized - # Merging of detector-level dia_source_detector [Parquet] to fakes_dia_source_visit [visit-level] - consolidateDiaSourceTable: - class: lsst.pipe.tasks.postprocess.ConsolidateSourceTableTask - config: - connections.inputCatalogs: dia_source_detector - connections.outputCatalog: fakes_dia_source_visit # Conversion of preliminary_visit_summary [visit-level afw.table] to fakes_visit_table [instrument-level Parquet] makeVisitTable: class: lsst.pipe.tasks.postprocess.MakeVisitTableTask