Remove result collector

alembic/versions/0b1a8b3e1e0f_drop_result_collector_task.py

@@ -0,0 +1,41 @@
+"""Drop result collector task
+
+Revision ID: 0b1a8b3e1e0f
+Revises: 7c643a1823db
+Create Date: 2017-11-13 14:40:16.176999
+
+"""
+
+# revision identifiers, used by Alembic.
+revision = '0b1a8b3e1e0f'
+down_revision = '7c643a1823db'
+branch_labels = None
+depends_on = None
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('package_worker_results',
+                  sa.Column('s3_version_id',
+                            sa.String(length=255), nullable=True))
+    op.drop_column('package_worker_results', 'task_result')
+    op.add_column('worker_results',
+                  sa.Column('s3_version_id',
+                            sa.String(length=255), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('worker_results', 's3_version_id')
+    op.add_column('package_worker_results',
+                  sa.Column('task_result',
+                            postgresql.JSONB(astext_type=sa.Text()),
+                            autoincrement=False,
+                            nullable=True))
+    op.drop_column('package_worker_results', 's3_version_id')
+    # ### end Alembic commands ###

f8a_worker/dispatcher/flows/bayesianFlow.yml

@@ -38,20 +38,8 @@
         - from: 'bayesianAnalysisFlow'
           to: 'FinalizeTask'
         - from: 'FinalizeTask'
-          to: 'ResultCollector'
-          condition:
-            name: 'envEqual'
-            args:
-              env: 'BAYESIAN_SYNC_S3'
-              value: '1'
+          to: 'GraphImporterTask'
         - from: 'FinalizeTaskError'
-          to: 'ResultCollector'
-          condition:
-            name: 'envEqual'
-            args:
-              env: 'BAYESIAN_SYNC_S3'
-              value: '1'
-        - from: 'ResultCollector'
           to: 'GraphImporterTask'
       failures:
         - nodes:

f8a_worker/dispatcher/flows/bayesianPackageFlow.yml

@@ -41,8 +41,6 @@
         - from: 'bayesianPackageTaggingFlow'
           to: 'PackageFinalizeTask'
         - from: 'PackageFinalizeTask'
-          to: 'PackageResultCollector'
-        - from: 'PackageResultCollector'
           to: 'PackageGraphImporterTask'
         - from: 'PackageFinalizeTaskError'
           to: 'PackageGraphImporterTask'