Merge pull request #19740 from MushuEE/kettle/add_staging_stream

Add sub stream results to staging
kubernetes · Nov 2, 2020 · 5b7a659 · 5b7a659
2 parents dcf6b52 + b227869
commit 5b7a659
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kettle/update.py b/kettle/update.py
@@ -70,7 +70,8 @@ def main():
     else:
         call(f'{mj_cmd} | pv | gzip > build_staging.json.gz')
         call(f'{bq_cmd} k8s-gubernator:build.staging build_staging.json.gz schema.json')
-
+        call('python3 stream.py --poll kubernetes-jenkins/gcs-changes/kettle ' \
+            ' --dataset k8s-gubernator:build --tables staging:0 --stop_at=1')
 
 if __name__ == '__main__':
     os.chdir(os.path.dirname(__file__))