CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-06-26 10:10:57 +12:00
Code Issues Projects Releases Wiki Activity

Removed not working co-runs

Browse source
This commit is contained in:
Eldad Fux 2021-01-26 21:16:03 +02:00
parent d908606509
commit fdd413a4b3
2 changed files with 4 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
app/workers/functions.php
View file

@ -184,9 +184,7 @@ class FunctionsV1
Console::success('Triggered function: '.$event);
Swoole\Coroutine\run(function () use ($projectId, $database, $function, $event, $payload) {
$this->execute('event', $projectId, '', $database, $function, $event, $payload);
});
$this->execute('event', $projectId, '', $database, $function, $event, $payload);
}
}
break;
@ -242,9 +240,7 @@ class FunctionsV1
'scheduleOriginal' => $function->getAttribute('schedule', ''),
]); // Async task rescheduale
Swoole\Coroutine\run(function () use ($trigger, $projectId, $executionId, $database, $function) {
$this->execute($trigger, $projectId, $executionId, $database, $function);
});
$this->execute($trigger, $projectId, $executionId, $database, $function);
break;
@ -257,9 +253,7 @@ class FunctionsV1
throw new Exception('Function not found ('.$functionId.')');
}
Swoole\Coroutine\run(function () use ($trigger, $projectId, $executionId, $database, $function) {
$this->execute($trigger, $projectId, $executionId, $database, $function);
});
$this->execute($trigger, $projectId, $executionId, $database, $function);
break;
default:

2
src/Appwrite/Database/Database.php
View file

@ -214,7 +214,7 @@ class Database
/**
* @param array $data
*
* @return Document|bool
* @return Document
*
* @throws AuthorizationException
* @throws StructureException