From cd9a52fff00e7f25b2819aecbdd09afe2c9d454e Mon Sep 17 00:00:00 2001 From: Brianna Smart Date: Wed, 8 May 2024 11:12:36 -0700 Subject: [PATCH] Update connection Update connection to reflect longTrailedSources now originate from filterDiaSourceCatalog --- pipelines/_ingredients/ApPipe.yaml | 6 +++--- pipelines/_ingredients/ApPipeWithFakes.yaml | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pipelines/_ingredients/ApPipe.yaml b/pipelines/_ingredients/ApPipe.yaml index 954bc11..8028589 100644 --- a/pipelines/_ingredients/ApPipe.yaml +++ b/pipelines/_ingredients/ApPipe.yaml @@ -162,6 +162,9 @@ contracts: - contract: filterDiaSrcCat.connections.ConnectionsClass(config=filterDiaSrcCat).filteredDiaSourceCat.name == sampleSpatialMetrics.connections.ConnectionsClass(config=sampleSpatialMetrics).diaSources.name msg: "filterDiaSrcCat.filteredDiaSourceCat != sampleSpatialMetrics.diaSources" + - contract: filterDiaSrcCat.connections.ConnectionsClass(config=filterDiaSrcCat).longTrailedSources.name == + analyzeTrailedDiaSrcCore.connections.ConnectionsClass(config=analyzeTrailedDiaSrcCore).data.name + msg: "filterDiaSrcCat.longTrailedSources != analyzeTrailedDiaSrcCore.data" - contract: (not transformDiaSrcCat.doIncludeReliability) or (rbClassify.connections.ConnectionsClass(config=rbClassify).classifications.name == transformDiaSrcCat.connections.ConnectionsClass(config=transformDiaSrcCat).reliability.name) @@ -176,9 +179,6 @@ contracts: - contract: diaPipe.connections.ConnectionsClass(config=diaPipe).associatedDiaSources.name == analyzeAssocDiaSrcCore.connections.ConnectionsClass(config=analyzeAssocDiaSrcCore).data.name msg: "diaPipe.associatedDiaSources != analyzeAssocDiaSrcCore.data" - - contract: diaPipe.connections.ConnectionsClass(config=diaPipe).longTrailedSources.name == - analyzeTrailedDiaSrcCore.connections.ConnectionsClass(config=analyzeTrailedDiaSrcCore).data.name - msg: "diaPipe.longTrailedSources != analyzeTrailedDiaSrcCore.data" - contract: sampleSpatialMetrics.connections.ConnectionsClass(config=sampleSpatialMetrics).spatiallySampledMetrics.name == diffimTaskPlots.connections.ConnectionsClass(config=diffimTaskPlots).data.name msg: "sampleSpatialMetrics.spatiallySampledMetrics != diffimTaskPlots.data" diff --git a/pipelines/_ingredients/ApPipeWithFakes.yaml b/pipelines/_ingredients/ApPipeWithFakes.yaml index dc730ae..b604a9e 100644 --- a/pipelines/_ingredients/ApPipeWithFakes.yaml +++ b/pipelines/_ingredients/ApPipeWithFakes.yaml @@ -224,7 +224,7 @@ contracts: - contract: diaPipe.connections.ConnectionsClass(config=diaPipe).associatedDiaSources.name == analyzeAssocDiaSrcCore.connections.ConnectionsClass(config=analyzeAssocDiaSrcCore).data.name msg: "diaPipe.associatedDiaSources != analyzeAssocDiaSrcCore.data" - - contract: diaPipe.connections.ConnectionsClass(config=diaPipe).longTrailedSources.name == + - contract: filterDiaSrcCat.connections.ConnectionsClass(config=filterDiaSrcCat).longTrailedSources.name == analyzeTrailedDiaSrcCore.connections.ConnectionsClass(config=analyzeTrailedDiaSrcCore).data.name msg: "diaPipe.longTrailedSources != analyzeTrailedDiaSrcCore.data" - contract: sampleSpatialMetrics.connections.ConnectionsClass(config=sampleSpatialMetrics).spatiallySampledMetrics.name ==