https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
header.insert_query, header.insert_settings, header.client_info};
        CheckingCompressedReadBuffer checking_in(in);
        remote.writePrefix();
        remote.writePrepared(checking_in);
        remote.writeSuffix();
    }
    catch (const Exception & e)
    {
        maybeMarkAsBroken(file_path, e);
        throw;
    }
    auto dir_sync_guard = getDirectorySyncGuard(dir_fsync, disk, relative_path);
    Poco::File{file_path}.remove();
    metric_pending_files.sub();
    LOG_TRACE(log, "Finished processing `{}`", file_path);
}
struct StorageDistributedDirectoryMonitor::BatchHeader
{
    Settings settings;
    String query;
    ClientInfo client_info;
    String sample_block_structure;
    BatchHeader(Settings settings_, String query_, ClientInfo client_info_, String sample_block_structure_)
        : settings(std::move(settings_))
        , query(std::move(query_))
        , client_info(std::move(client_info_))
        , sample_block_structure(std::move(sample_block_structure_))
    {
    }
    bool operator==(const BatchHeader & other) const