Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 08:58:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix: tests as per the latest databases changes.

Browse source
This commit is contained in:
Darshan 2025-04-19 19:17:25 +05:30
parent 12b816178b
commit 511cf72013
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/Appwrite/Platform/Workers/Deletes.php
View file

@ -1202,26 +1202,26 @@ class Deletes extends Action
): void {
$start = \microtime(true);
/**
* deleteDocuments uses a cursor, we need to add a unique order by field or use default
*/
$count = 0;
try {
$documents = $database->deleteDocuments($collection, $queries);
$database->deleteDocuments(
collection: $collection,
queries: $queries,
onNext: function (Document $document) use (&$count, $callback) {
$count++;
if (\is_callable($callback)) {
$callback($document);
}
}
);
} catch (Throwable $th) {
$tenant = $database->getSharedTables() ? 'Tenant:'.$database->getTenant() : '';
Console::error("Failed to delete documents for collection:{$database->getNamespace()}_{$collection} {$tenant} :{$th->getMessage()}");
return;
}
if (\is_callable($callback)) {
foreach ($documents as $document) {
$callback($document);
}
}
$end = \microtime(true);
$count = \count($documents);
Console::info("Deleted {$count} documents by group in " . ($end - $start) . " seconds");
}