Forward porting singleton warn vs error for Cron.
This commit is contained in:
parent
a30d4140d9
commit
aabec44de8
3 changed files with 11 additions and 2 deletions
|
|
@ -291,6 +291,13 @@ sub www_runCronJob {
|
|||
priority => $task->get("priority"),
|
||||
});
|
||||
if ( !$instance ) {
|
||||
if ($session->stow->get('singletonWorkflowClash')) {
|
||||
$session->errorHandler->warn(
|
||||
"Could not create workflow instance for workflowId '" . $task->get( "workflowId" )
|
||||
. "': It is a singleton workflow and is still running from the last invocation."
|
||||
);
|
||||
return "done";
|
||||
}
|
||||
$session->errorHandler->error(
|
||||
"Could not create workflow instance for workflowId '" . $task->get( "workflowId" )
|
||||
. "': The result was undefined"
|
||||
|
|
|
|||
|
|
@ -73,8 +73,10 @@ sub create {
|
|||
$sql .= ' and parameters IS NULL';
|
||||
}
|
||||
my ($count) = $session->db->quickArray($sql,$placeHolders);
|
||||
$session->stow->set('singletonWorkflowClash', 0);
|
||||
if ($isSingleton && $count) {
|
||||
$session->log->info("An instance of singleton workflow $properties->{workflowId} already exists, not creating a new one");
|
||||
$session->stow->set('singletonWorkflowClash', 1);
|
||||
return undef
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue