Updated client side logging and attempt to include proper job_id
This commit is contained in:
@@ -45,19 +45,20 @@ function gearman_complete($method, $handle, $result) {
|
|||||||
$main = RippingCluster_Main::instance();
|
$main = RippingCluster_Main::instance();
|
||||||
$log = $main->log();
|
$log = $main->log();
|
||||||
|
|
||||||
/*$log->info("Job Complete", $job->id());*/
|
$job = RippingCluster_Job::fromId($result['id']);
|
||||||
RippingCluster_LogEntry::info($log, 'Job complete', 'batch');
|
$job->updateStatus(RippingCluster_JobStatus::COMPLETE);
|
||||||
|
|
||||||
|
RippingCluster_ClientLogEntry::info($log, $job->id(), 'Job complete');
|
||||||
}
|
}
|
||||||
|
|
||||||
function gearman_fail($task) {
|
function gearman_fail($task) {
|
||||||
$main = RippingCluster_Main::instance();
|
$main = RippingCluster_Main::instance();
|
||||||
$log = $main->log();
|
$log = $main->log();
|
||||||
|
|
||||||
/*$job = RippingCluster_Job::fromId($gearman_task->unique());
|
$job = RippingCluster_Job::fromId($task->args['rip_options']['id']);
|
||||||
$job->updateStatus(RippingCluster_JobStatus::FAILED);
|
$job->updateStatus(RippingCluster_JobStatus::FAILED);
|
||||||
|
|
||||||
$log->info("Job Failed", $job->id());*/
|
RippingCluster_ClientLogEntry::info($log, $job->id(), 'Job failed');
|
||||||
RippingCluster_LogEntry::info($log, 'Job failed', 'batch');
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user