diff --git a/app/workers/click_house/event_paths_consistency_cron_worker.rb b/app/workers/click_house/event_paths_consistency_cron_worker.rb index 71a1fb0995fb4c31d0c1bf9874f6756db7df9deb..e115aa6b7e912242a6b959a05bafe19e1c2d5b1a 100644 --- a/app/workers/click_house/event_paths_consistency_cron_worker.rb +++ b/app/workers/click_house/event_paths_consistency_cron_worker.rb @@ -83,13 +83,13 @@ def delete_records_from_click_house(id_paths) paths = id_paths.map(&:second).map { |value| "'#{value}'" }.join(',') query = ClickHouse::Client::Query.new( - raw_query: "DELETE FROM events WHERE path IN (#{paths})" + raw_query: "ALTER TABLE events DELETE WHERE path IN (#{paths})" ) connection.execute(query) query = ClickHouse::Client::Query.new( - raw_query: 'DELETE FROM event_namespace_paths WHERE namespace_id IN ({namespace_ids:Array(UInt64)})', + raw_query: 'ALTER TABLE event_namespace_paths DELETE WHERE namespace_id IN ({namespace_ids:Array(UInt64)})', placeholders: { namespace_ids: id_paths.map(&:first).to_json } )