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.
tenzir · Dec 19, 2024 · c31fe57 · c31fe57
1 parent 793cf68
commit c31fe57
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/libtenzir/builtins/connectors/curl.cpp b/libtenzir/builtins/connectors/curl.cpp
@@ -406,6 +406,14 @@ class load_http_operator final : public crtp_operator<load_http_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<save_http_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);