From c31fe5794b6860af504067ebbfe464bd056e0a94 Mon Sep 17 00:00:00 2001 From: Dominik Lohmann Date: Thu, 19 Dec 2024 10:55:59 +0100 Subject: [PATCH] Mark `{load,save}_http` as detached The operators use blocking API calls, so on a system with little parallelism they were able to get the node to a halt. --- libtenzir/builtins/connectors/curl.cpp | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/libtenzir/builtins/connectors/curl.cpp b/libtenzir/builtins/connectors/curl.cpp index d9a864bc95c..3534a6caba5 100644 --- a/libtenzir/builtins/connectors/curl.cpp +++ b/libtenzir/builtins/connectors/curl.cpp @@ -406,6 +406,14 @@ class load_http_operator final : public crtp_operator { } } + auto location() const -> operator_location override { + return operator_location::local; + } + + auto detached() const -> bool override { + return true; + } + auto optimize(expression const& filter, event_order order) const -> optimize_result override { TENZIR_UNUSED(filter, order); @@ -448,6 +456,14 @@ class save_http_operator final : public crtp_operator { } } + auto location() const -> operator_location override { + return operator_location::local; + } + + auto detached() const -> bool override { + return true; + } + auto optimize(expression const& filter, event_order order) const -> optimize_result override { TENZIR_UNUSED(filter, order);