feat: udf v2 (#25642)

posthog/user_scripts/v2/aggregate_funnel

@@ -0,0 +1,9 @@
+#!/bin/sh
+
+DIR_NAME=$(dirname "$0")
+
+case $( uname -m ) in
+aarch64) $DIR_NAME/aggregate_funnel_aarch64 "$@";;
+*) $DIR_NAME/aggregate_funnel_x86_64 "$@";;
+esac
+

posthog/user_scripts/v2/aggregate_funnel_array_trends_test.py

@@ -0,0 +1,13 @@
+#!/usr/bin/python3
+
+import sys
+import json
+
+if __name__ == "__main__":
+    for line in sys.stdin:
+        try:
+            print(json.dumps({"result": line}))  # noqa: T201
+            # calculate_funnel_trends_from_user_events(*parse_args(line))
+        except Exception as e:
+            print(json.dumps({"result": json.dumps(str(e))}), end="\n")  # noqa: T201
+        sys.stdout.flush()

posthog/user_scripts/v2/aggregate_funnel_test.py

@@ -0,0 +1,14 @@
+#!/usr/bin/python3
+import json
+
+import sys
+import traceback
+
+if __name__ == "__main__":
+    for line in sys.stdin:
+        try:
+            # calculate_funnel_from_user_events(*parse_args(line))
+            print(json.dumps({"result": line}))  # noqa: T201
+        except Exception as e:
+            print(json.dumps({"result": json.dumps(str(e) + traceback.format_exc())}), end="\n")  # noqa: T201
+        sys.stdout.flush()