- print x["properties"]["text"]
- elif x["event_type"] in ("create", "update"):
- if args.job or x["object_kind"] == "arvados#pipeline_instance":
- if x["properties"]["new_attributes"]["state"] in ("Complete", "Failed", "Cancelled"):
- ws.close_connection()
- if x["object_kind"] == "arvados#pipeline_instance":
- pipeline_jobs = set()
- for c in x["properties"]["new_attributes"]["components"]:
- if "job" in x["properties"]["new_attributes"]["components"][c]:
- pipeline_jobs.add(x["properties"]["new_attributes"]["components"][c]["job"]["uuid"])
- if known_component_jobs != pipeline_jobs:
- ws.unsubscribe(filters)
- filters = [['object_uuid', 'in', [args.pipeline] + list(pipeline_jobs)]]
- ws.subscribe([['object_uuid', 'in', [args.pipeline] + list(pipeline_jobs)]])
- known_component_jobs = pipeline_jobs
+ sys.stdout.write(ev["properties"]["text"])
+ elif ev["event_type"] in ("create", "update"):
+ if ev["object_kind"] == "arvados#pipelineInstance":
+ update_subscribed_components(ev["properties"]["new_attributes"]["components"])
+ elif 'status' in ev and ev['status'] == 200:
+ pass