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)));
}
}
}