pegasus-plots does not plot

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

XMLWordPrintable

      I am working through the tutorial-vm and attempting to run a pegasus-plots on a black diamond on a CentOS 5.7. Neither python 2.4 nor 2.6 are working:

      pegasus-wms $ python26 /opt/pegasus/default/bin/pegasus-plots -p all dags/tutorial/pegasus/blackdiamond/run0001
      2011-12-12 15:08:02,414:utils.py:create_directory:123: WARNING: Deleting existing directory. Deleting... /home/tutorial/pegasus-wms/dags/tutorial/pegasus/blackdiamond/run0001/plots
      2011-12-12 15:08:02,554:pegasus-plots:main:598: WARNING: Traceback (most recent call last):
      File "/opt/pegasus/default/bin/pegasus-plots", line 596, in main
      create_charts(submit_dir, output_dir,options.config_properties, log_level_str)
      File "/opt/pegasus/default/bin/pegasus-plots", line 426, in create_charts
      populate.populate_job_instance_details(wf_stats, wf_info)
      File "/opt/pegasus/default/lib/python/Pegasus/plots_stats/plots/populate.py", line 251, in populate_job_instance_details
      job_states_list = workflow_stats.get_job_states()
      File "/opt/pegasus/default/lib/python/netlogger/analysis/workflow/stampede_statistics.py", line 778, in get_job_states
      return q.all()
      File "/opt/pegasus/default/lib/python/sqlalchemy/orm/query.py", line 1492, in all
      return list(self)
      File "/opt/pegasus/default/lib/python/sqlalchemy/orm/query.py", line 1604, in _iter_
      return self._execute_and_instances(context)
      File "/opt/pegasus/default/lib/python/sqlalchemy/orm/query.py", line 1609, in _execute_and_instances
      mapper=self._mapper_zero_or_none())
      File "/opt/pegasus/default/lib/python/sqlalchemy/orm/session.py", line 701, in execute
      clause, params or {})
      File "/opt/pegasus/default/lib/python/sqlalchemy/engine/base.py", line 1194, in execute
      params)
      File "/opt/pegasus/default/lib/python/sqlalchemy/engine/base.py", line 1274, in _execute_clauseelement
      return self.__execute_context(context)
      File "/opt/pegasus/default/lib/python/sqlalchemy/engine/base.py", line 1305, in __execute_context
      context.parameters[0], context=context)
      File "/opt/pegasus/default/lib/python/sqlalchemy/engine/base.py", line 1404, in _cursor_execute
      context)
      File "/opt/pegasus/default/lib/python/sqlalchemy/engine/base.py", line 1397, in _cursor_execute
      context)
      File "/opt/pegasus/default/lib/python/sqlalchemy/engine/default.py", line 299, in do_execute
      cursor.execute(statement, parameters)
      OperationalError: (OperationalError) no such function: group_concat u'SELECT job.job_id AS job_job_id, job_instance.job_instance_id AS job_instance_job_instance_id, job_instance.job_submit_seq AS job_instance_job_submit_seq, job.exec_job_id AS job_name, job_instance.site AS job_instance_site, (SELECT host.hostname \nFROM host \nWHERE host.host_id = job_instance.host_id) AS host_name, CAST((SELECT min(jobstate.timestamp) AS min_1 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id) AS FLOAT) AS "jobS", CAST((SELECT max(jobstate.timestamp) - min(jobstate.timestamp) AS anon_1 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id) AS FLOAT) AS "jobDuration", CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) AS FLOAT) AS pre_start, CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) - (SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) AS FLOAT) AS pre_duration, CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) AS FLOAT) AS condor_start, CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) - (SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) AS FLOAT) AS condor_duration, CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN (?, ?)) AS FLOAT) AS grid_start, CAST((SELECT min(jobstate.timestamp) AS min_2 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) - (SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN (?, ?)) AS FLOAT) AS grid_duration, CAST((SELECT max(jobstate.timestamp) AS max_1 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN (?, ?)) AS FLOAT) AS exec_start, CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) - (SELECT max(jobstate.timestamp) AS max_1 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN (?, ?)) AS FLOAT) AS exec_duration, CAST((SELECT min(invocation.start_time) AS min_3 \nFROM invocation \nWHERE invocation.job_instance_id = job_instance.job_instance_id AND invocation.wf_id = job.wf_id AND invocation.task_submit_seq >= ? GROUP BY invocation.job_instance_id) AS FLOAT) AS kickstart_start, CAST((SELECT sum(invocation.remote_duration) AS sum_1 \nFROM invocation \nWHERE invocation.job_instance_id = job_instance.job_instance_id AND invocation.wf_id = job.wf_id AND invocation.task_submit_seq >= ? GROUP BY invocation.job_instance_id) AS FLOAT) AS kickstart_duration, CAST((SELECT max(jobstate.timestamp) AS max_2 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN (?, ?)) AS FLOAT) AS post_start, CAST((SELECT jobstate.timestamp \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN ) - (SELECT max(jobstate.timestamp) AS max_2 \nFROM jobstate \nWHERE jobstate.job_instance_id = job_instance.job_instance_id AND jobstate.state IN (?, ?)) AS FLOAT) AS post_duration, (SELECT group_concat(distinct(invocation.transformation)) AS group_concat_1 \nFROM invocation \nWHERE invocation.wf_id IN AND invocation.job_instance_id = job_instance.job_instance_id AND invocation.transformation != ? AND invocation.transformation != ?) AS transformation \nFROM job, job_instance \nWHERE job_instance.job_id = job.job_id AND job.wf_id IN ORDER BY job_instance.job_submit_seq' ('PRE_SCRIPT_STARTED', 'PRE_SCRIPT_TERMINATED', 'PRE_SCRIPT_STARTED', 'SUBMIT', 'JOB_TERMINATED', 'SUBMIT', 'GRID_SUBMIT', 'GLOBUS_SUBMIT', 'EXECUTE', 'GRID_SUBMIT', 'GLOBUS_SUBMIT', 'EXECUTE', 'SUBMIT', 'JOB_TERMINATED', 'EXECUTE', 'SUBMIT', 0, 0, 'POST_SCRIPT_STARTED', 'JOB_TERMINATED', 'POST_SCRIPT_TERMINATED', 'POST_SCRIPT_STARTED', 'JOB_TERMINATED', 1, 'dagman::post', 'dagman::pre', 1)

            Assignee:
            Karan Vahi
            Reporter:
            Jens Voeckler
            Archiver:
            Rajiv Mayani

              Created:
              Updated:
              Resolved:
              Archived: