This commit is contained in:
kssenii 2024-06-05 10:43:41 +02:00
parent ec3b82ba63
commit c25f8fa28c
2 changed files with 1 additions and 2 deletions

View File

@ -167,7 +167,7 @@ S3QueueMetadata::FileMetadataPtr S3QueueMetadata::getFileMetadata(
S3QueueOrderedFileMetadata::BucketInfoPtr bucket_info)
{
auto file_status = local_file_statuses->get(path, /* create */true);
switch (settings.mode)
switch (settings.mode.value)
{
case S3QueueMode::ORDERED:
return std::make_shared<S3QueueOrderedFileMetadata>(

View File

@ -371,7 +371,6 @@ void S3QueueOrderedFileMetadata::setProcessedImpl()
};
const auto zk_client = getZooKeeper();
const auto node_metadata_str = node_metadata.toString();
std::string failure_reason;
while (true)