diff --git a/src/main.cpp b/src/main.cpp index 5b9084f..3f6fdee 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -26,7 +26,7 @@ void batched_update(std::shared_ptr client_ptr, std::string spdlog::warn("No users to update"); return; } - const size_t batch_size = 5; + const size_t batch_size = 1; for (size_t base_iteration = 0; base_iteration < current_users.size(); base_iteration += batch_size) { std::vector> futures_for_this_batch; @@ -162,8 +162,10 @@ int main (int argc, char *argv[]) { std::thread update_thread = std::thread { [client_shared_ptr, base_uri](){ while(true){ batched_update(client_shared_ptr, base_uri); - sleep(5*60); - spdlog::info("Rerunning update cycle"); + for (size_t i = 0; i<5; i++) { + sleep(60); + spdlog::info("Daemon is still alive"); + } } } }; diff --git a/src/types.cpp b/src/types.cpp index 4b79222..12dcff8 100644 --- a/src/types.cpp +++ b/src/types.cpp @@ -69,7 +69,7 @@ uint16_t parse_date_to_clickhouse(const std::string& date_str) { // Try to parse YYYY-MM-DD format std::tm tm = {}; std::istringstream ss(date_str); - ss >> std::get_time(&tm, "%Y-%m-%d"); + ss >> std::get_time(&tm, "%m/%d/$Y"); if (ss.fail()) { spdlog::warn("Failed to parse date: {}, using epoch", date_str);