tripal_galaxy.drush.inc

<?php

/**
 * @file
 * Contains function relating to drush-integration of this module.
 */

/**
 * @defgroup tripal_drush Tripal Drush Integration @{ Contains function relating
 * to drush-integration of various tripal modules.
 * @}
 */

/**
 * Implements hook_drush_help().
 */
function tripal_galaxy_drush_help($command) {
  switch ($command) {

    // phpcs:disable Squiz.ControlStructures.SwitchDeclaration.SpacingAfterBreak
    // phpcs:disable Squiz.PHP.NonExecutableCode.Unreachable
    case 'trp-galaxy-invoke':
      return dt('Launches pending galaxy jobs waiting in the queue.');

    break;
    case 'trp-galaxy-status':
      return dt('Launches pending galaxy jobs waiting in the queue.');

    break;
    // phpcs:enable Squiz.PHP.NonExecutableCode.Unreachable
    // phpcs:enable Squiz.ControlStructures.SwitchDeclaration.SpacingAfterBreak
  }
}

/**
 * Implements hook_drush_command().
 */
function tripal_galaxy_drush_command() {
  $items = array();

  $items['trp-galaxy-invoke'] = array(
    'description' => dt('Launches pending galaxy jobs waiting in the queue.'),
    'examples' => array(
      'Single Job' => 'drush trp-galaxy-invoke --submission=512',
    ),
    'arguments' => array(),
    'options' => array(
      'submission' => dt('The submission ID of the workflow to run.'),
    ),
  );
  $items['trp-galaxy-status'] = array(
    'description' => dt('Updates the status of galaxy jobs.'),
    'examples' => array(
      'Single Job' => 'drush trp-galaxy-status --submission=512',
    ),
    'arguments' => array(),
    'options' => array(
      'submission' => dt('The submission ID of the workflow to run.'),
      'force' => dt('Forces update of status for jobs that are already have a satus of Completed or Error.'),
    ),
  );
  return $items;
}

/**
 * Function for 'trp-galaxy-invoke' command.
 */
function drush_tripal_galaxy_trp_galaxy_invoke() {
  $sid = drush_get_option('submission');
  if (!$sid) {
    drush_error('Please provide a submission id (ie.g. --submission=512).');
  }
  drush_print('Launching workflow...');
  try {
    tripal_galaxy_invoke_webform_submission($sid);
    drush_print('Done.');
  }
  catch (Exception $e) {
    drush_set_error("Cannot launch workflow: " . $e->getMessage());
  }
}

/**
 * Function for 'trp-galaxy-status' command.
 */
function drush_tripal_galaxy_trp_galaxy_status() {
  $sid = drush_get_option('submission');
  $force = drush_get_option('force');

  if (!$force) {
    $force = FALSE;
  }
  else {
    $force = TRUE;
  }

  if ($sid) {
    drush_print('Updating status of workflow...');
    tripal_galaxy_check_submission_status($sid, $force);
    drush_print('Done.');
    // drush_set_error('Please provide a submission id (ie.g.
    // --submission=512).');.
  }
  else {
    drush_print('Updating status of all workflows...');
    tripal_galaxy_check_submission_status(FALSE, $force);
    drush_print('Done.');
  }
}