add update job that appends a literal reference

to refer/referd to tasks for RT

__This is not idempotent__

1 files changed, 17 insertions, 12 deletions

diff --git a/rt_update_tasks.py b/rt_update_tasks.py
index 47921d4..d8adc5c 100755
--- a/rt_update_tasks.py
+++ b/rt_update_tasks.py
@@ -40,24 +40,29 @@ def update(bugid):
 
     blocker_ref = extref(bugid)
     tinfo = json.loads(header[0][0])
+    
+    upstream = []
 
-    if 'blocks' not in tinfo['links']:
-        log("%s doesn't block anything" % (str(bugid),))
-        return True
+    if 'parent' in tinfo['links']:
+        upstream += tinfo['links']['parent']
+
+    if 'blocks' in tinfo['links']:
+        upstream += tinfo['links']['blocks']
 
-    for b in tinfo['links']['blocks']:
-        blocked_ref = extref(b)
-        log("%s is blocking %s" % (blocker_ref,
-                                   blocked_ref))
-        if blocked_ref:
-            log(phabdb.set_blocked_task(blocker_ref,
+    if upstream:
+        for b in upstream:
+            blocked_ref = extref(b)
+            log("%s is blocking %s" % (blocker_ref,
+                                       blocked_ref))
+            if blocked_ref:
+                log(phabdb.set_blocked_task(blocker_ref,
                                         blocked_ref))
-        else:
-            log('%s is missing blocker %s' % (blocked_ref,
+            else:
+                log('%s is missing blocker %s' % (blocked_ref,
                                               blocker_ref))
-
     blocks = phabdb.get_tasks_blocked(blocker_ref)
     vlog('%s is blocking %s' % (blocker_ref, str(blocks)))
+
     current = pmig.sql_x("SELECT * \
                           from task_relations \
                           WHERE id = %s", bugid)