Uploaded image for project: 'Pegasus'
  1. Pegasus
  2. PM-668

total succeeded/failed jobs query is incorrect when a sub workflow is retried

    XMLWordPrintable

    Details

      Description

      For the case where the a sub workflow is retried and then succeeds the query results in correct results.

      The incorrect query that is implemented is



      // API method name : get_total_succeeded_jobs_status() expand_workflow = true, job_filter = all
       
      SELECT count(i1.job_instance_id) last_job_instance_id FROM
       (SELECT max(job_submit_seq) jss, i.job_id jobid FROM
        workflow w, job j, job_instance i WHERE
        w.wf_id = 1 and
        w.wf_id=j.wf_id and
        j.job_id = i.job_id and
        i.exitcode = 0 and
        i.exitcode IS NOT NULL
        GROUP by i.job_id), job_instance i1 WHERE
      i1.job_id = job_id and i1.job_submit_seq = jss
       
      // expand_workflow = true , job_filter = 'nonsub'
      //Only change from the all filter query is an extra filter 'and j.type_desc not in ('dax','dag')
      all query + following filter in the sub query as show below and j.type_desc not in ('dax','dag')
       
      // expand_workflow = true , job_filter = 'subwf'
      //Only change from the all filter query is an extra filter 'and j.type_desc in ('dax','dag')
      all query + and j.type_desc in ('dax','dag') [filter inside sub query]
       
      // expand_workflow = true , job_filter = 'dax'
      //Only change from the all filter query is an extra filter 'and j.type_desc in ('dax')
      all query + and j.type_desc in ('dax') [filter inside sub query]
       
      // expand_workflow = true , job_filter = 'dag'
      //Only change from the all filter query is an extra filter 'and j.type_desc in ('dag')
      all query + and type_desc not in ('dag') [filter inside sub query]
       
      // expand_workflow = true , job_filter = 'compute'
      //Only change from the all filter query is an extra filter 'and t.type_desc in ('compute')
      all query + and type_desc in ('compute') [filter inside sub query]

        Attachments

          Activity

            People

            • Assignee:
              vahi Karan Vahi
              Reporter:
              gmehta Gaurang Mehta (Inactive)
            • Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: