function drush_tripal_bulk_loader_tripal_loader_submit

2.x tripal_bulk_loader.drush.inc drush_tripal_bulk_loader_tripal_loader_submit($nid)
3.x tripal_bulk_loader.drush.inc drush_tripal_bulk_loader_tripal_loader_submit($nid)
1.x tripal_bulk_loader.drush.inc drush_tripal_bulk_loader_tripal_loader_submit($nid)

Submit or Re-submit the given bulk loading job.

Parameters

$nid: The Node ID of the bulk Loading Job

Related topics

File

tripal_bulk_loader/tripal_bulk_loader.drush.inc, line 144
Implements drush integration for this module

Code

function drush_tripal_bulk_loader_tripal_loader_submit($nid) {
  global $user;

  if ($node->job_id) {
    //Re-submit Tripal Job
    tripal_rerun_job($node->job_id);
    db_query("UPDATE {tripal_bulk_loader} SET job_status='%s' WHERE nid=%d", 'Submitted to Queue', $nid);
  }
  else {
    //Submit Tripal Job
    $node = node_load($nid);
    $job_args[1] = $nid;
    if (is_readable($node->file)) {
      $fname = basename($node->file);
      $job_id = tripal_add_job("Bulk Loading Job: $fname", 'tripal_bulk_loader', 'tripal_bulk_loader_load_data', $job_args, $user->uid);

      // add job_id to bulk_loader node
      $success = db_query("UPDATE {tripal_bulk_loader} SET job_id=%d WHERE nid=%d", $job_id, $nid);

      // change status
      db_query("UPDATE {tripal_bulk_loader} SET job_status='%s' WHERE nid=%d", 'Submitted to Queue', $nid);
    }
    else {
      drupal_set_message(t("Can not open %file. Job not scheduled.", array('%file' => $node->file)));
    }
  }

}