Fix uncaught exception in background tasj

This commit is contained in:
kssenii 2023-10-16 17:31:30 +02:00
parent 3cd175d11d
commit 4bc32c6387

View File

@ -322,8 +322,19 @@ void DatabasePostgreSQL::loadStoredObjects(ContextMutablePtr /* context */, Load
void DatabasePostgreSQL::removeOutdatedTables() void DatabasePostgreSQL::removeOutdatedTables()
{ {
std::lock_guard lock{mutex}; std::lock_guard lock{mutex};
std::set<std::string> actual_tables;
try
{
auto connection_holder = pool->get(); auto connection_holder = pool->get();
auto actual_tables = fetchPostgreSQLTablesList(connection_holder->get(), configuration.schema); actual_tables = fetchPostgreSQLTablesList(connection_holder->get(), configuration.schema);
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);
cleaner_task->scheduleAfter(cleaner_reschedule_ms);
return;
}
if (cache_tables) if (cache_tables)
{ {