remove bayesian{PackageTagging,Summary}Flow

fabric8-analytics · Nov 22, 2018 · fe3f736 · fe3f736
1 parent f30a78b
commit fe3f736
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 20 deletions.
diff --git a/f8a_worker/dispatcher/flows/bayesianPackageFlow.yml b/f8a_worker/dispatcher/flows/bayesianPackageFlow.yml
@@ -5,7 +5,6 @@
       queue: '{DEPLOYMENT_PREFIX}_ingestion_bayesianPackageFlow_v0'
       propagate_node_args:
         - 'bayesianPackageAnalysisFlow'
-        - 'bayesianPackageTaggingFlow'
       node_args_from_first: true
       nowait: 'PackageGraphImporterTask'
       sampling:
@@ -22,18 +21,7 @@
             args:
               key: 'document_id'
         - from: 'bayesianPackageAnalysisFlow'
-          to: 'bayesianPackageTaggingFlow'
-          condition: &shouldSchedulePackageTaggingCheck
-            name: 'alwaysFalse'
-        - from: 'bayesianPackageAnalysisFlow'
-          to: 'PackageFinalizeTask'
-          condition:
-            not:
-              <<: *shouldSchedulePackageTaggingCheck
-        - from: 'bayesianPackageTaggingFlow'
           to: 'PackageFinalizeTask'
-          condition:
-            <<: *shouldSchedulePackageTaggingCheck
         - from: 'PackageFinalizeTask'
           to: 'PackageResultCollector'
         - from: 'PackageResultCollector'
@@ -56,10 +44,6 @@
                   value: true
       failures:
         - nodes: 'bayesianPackageAnalysisFlow'
-          fallback: 'bayesianPackageTaggingFlow'
-          condition:
-            <<: *shouldSchedulePackageTaggingCheck
-        - nodes: 'bayesianPackageTaggingFlow'
           fallback: 'PackageFinalizeTaskError'
 
     - <<: *bayesianPackageFlow

diff --git a/f8a_worker/dispatcher/nodes.yml b/f8a_worker/dispatcher/nodes.yml
@@ -197,9 +197,7 @@
     - 'bayesianApiPackageFlow'
     - 'bayesianPriorityPackageFlow'
     - 'bayesianPackageAnalysisFlow'
-    - 'bayesianPackageTaggingFlow'
     - 'componentApiFlow'
-    - 'keywordsSummaryFlow'
     - 'keywordsApiSummaryFlow'
     - 'keywordsPrioritySummaryFlow'
     - 'dependencyIngestFlow'

diff --git a/f8a_worker/dispatcher/selective.py b/f8a_worker/dispatcher/selective.py
@@ -17,8 +17,7 @@ def selective_run_function(flow_name, node_name, node_args, task_names, storage_
     :return: ID of task that should be reused, None if task should be run again
     """
     try:
-        if flow_name in ('bayesianPackageFlow', 'bayesianPackageAnalysisFlow',
-                         'bayesianPackageTaggingFlow'):
+        if flow_name in ('bayesianPackageFlow', 'bayesianPackageAnalysisFlow'):
             task_result = storage_pool.get_connected_storage('PackagePostgres').\
                 get_latest_task_entry(
                     node_args['ecosystem'],