• Created by Unknown User (fabio), last modified on Feb 08, 2012

Introduction

pegasus-analyzer is a command line tool for debugging workflows.

Pegasus Analyzer Queries

In Pegasus 3.2, pegasus-analyzer can gather information either from files in the workflow directory (as in previous Pegasus releases) or using the Stampede database directory. Here we list the extra queries used to gather the needed information.


Failed Job Details

Failed Job Details
// Query for the failed job details
// Method in the retrieval API: get_job_instance_info

SELECT job_instance_id, site, stdout_file, stderr_file, stdout_text, stderr_text, work_dir,
 ( select submit_dir from workflow, job_instance where job_instance_id = 7 and wf_id = subwf_id) as subwf_dir, 
 ( select exec_job_id from job, job_instance where job.job_id = job_instance.job_id and job_instance.job_instance_id = 7 ) as job_name,
 ( select submit_file from job, job_instance where job.job_id = job_instance.job_id and job_instance.job_instance_id = 7 ) as submit_file,
 ( select executable from job, job_instance where job.job_id = job_instance.job_id and job_instance.job_instance_id = 7 ) as executable,
 ( select argv from job, job_instance where job.job_id == job_instance.job_id and job_instance.job_instance_id = 7 ) as argv,
 ( select submit_dir from workflow where wf_id = 1) as submit_dir,
 ( select state from jobstate where jobstate_submit_seq = (select max(jobstate_submit_seq) from jobstate where job_instance_id = 7) and job_instance_id = 7) as state,
 ( select executable from invocation where job_instance_id = 7 and task_submit_seq = -1) as pre_executable,
 ( select argv from invocation where job_instance_id = 7 and task_submit_seq = -1) as pre_argv,
 ( select hostname from host as h where h.host_id = job_instance.host_id) as hostname   
FROM job_instance where job_instance_id = 7;

 

List of Invocations for a Particular Job Instance

List of Invocations
// Query for obtaining a list of invocations for a particular job instance
// Method in the retrieval API: get_invocation_info
SELECT task_submit_seq, exitcode, executable, argv, transformation, abs_task_id FROM invocation WHERE job_instance_id = 7 and wf_id = 1

 

Failed Job Instances (using job states)

Failed Job Instances (job states)
// Query for obtaining the failed job instances for all jobs
// Method in the retrieval API: get_failed_job_instances (with FINAL=True and all_jobs=True)
  • No labels