Fix unit test

.github/workflows/ci.yml

@@ -13,10 +13,10 @@ jobs:
               with:
                   fetch-depth: 1
 
-            - name: Set up Python 3.11
+            - name: Set up Python 3.8
               uses: actions/setup-python@v2
               with:
-                  python-version: 3.11.11
+                  python-version: 3.8
 
             - uses: actions/cache@v3
               with:
@@ -42,26 +42,19 @@ jobs:
               run: |
                   isort --check-only .
 
-            - name: Check types with mypy
-              run: |
-                  mypy --no-site-packages --config-file mypy.ini  . | mypy-baseline filter
-
     tests:
-        name: Python ${{ matrix.python-version }} tests
+        name: Python tests
         runs-on: ubuntu-latest
-        strategy:
-            matrix:
-                python-version: ['3.9', '3.10', '3.11', '3.12', '3.13']
 
         steps:
             - uses: actions/checkout@v2
               with:
                   fetch-depth: 1
 
-            - name: Set up Python ${{ matrix.python-version }}
+            - name: Set up Python 3.9
               uses: actions/setup-python@v2
               with:
-                  python-version: ${{ matrix.python-version }}
+                  python-version: 3.9
 
             - name: Install requirements.txt dependencies with pip
               run: |

CHANGELOG.md

@@ -1,62 +1,6 @@
-## 3.19.0 – 2025-03-04
-
-1. Add support for tool calls in OpenAI and Anthropic.
-2. Add support for cached tokens.
-
-## 3.18.1 – 2025-03-03
-
-1. Improve quota-limited feature flag logs
-
-## 3.18.0 - 2025-02-28
-
-1. Add support for Azure OpenAI.
-
-## 3.17.0 - 2025-02-27
-
-1. The LangChain handler now captures tools in `$ai_generation` events, in property `$ai_tools`. This allows for displaying tools provided to the LLM call in PostHog UI. Note that support for `$ai_tools` in OpenAI and Anthropic SDKs is coming soon.
-
-## 3.16.0 - 2025-02-26
-
-1. feat: add some platform info to events (#198)
-
-## 3.15.1 - 2025-02-23
-
-1. Fix async client support for OpenAI.
-
-## 3.15.0 - 2025-02-19
-
-1. Support quota-limited feature flags
-
-## 3.14.2 - 2025-02-19
-
-1. Evaluate feature flag payloads with case sensitivity correctly.  Fixes <https://github.com/PostHog/posthog-python/issues/178>
-
-## 3.14.1 - 2025-02-18
-
-1. Add support for Bedrock Anthropic Usage
-
-## 3.13.0 - 2025-02-12
-
-1. Automatically retry connection errors
-
-## 3.12.1 - 2025-02-11
-
-1. Fix mypy support for 3.12.0
-2. Deprecate `is_simple_flag`
-
-## 3.12.0 - 2025-02-11
-
-1. Add support for OpenAI beta parse API.
-2. Deprecate `context` parameter
-
-## 3.11.1 - 2025-02-06
-
-1. Fix LangChain callback handler to capture parent run ID.
-
 ## 3.11.0 - 2025-01-28
 
 1. Add the `$ai_span` event to the LangChain callback handler to capture the input and output of intermediary chains.
-
    > LLM observability naming change: event property `$ai_trace_name` is now `$ai_span_name`.
 
 2. Fix serialiazation of Pydantic models in methods.

README.md

@@ -10,10 +10,8 @@ Please see the [Python integration docs](https://posthog.com/docs/integrations/p
 ### Testing Locally
 
 1. Run `python3 -m venv env` (creates virtual environment called "env")
-    * or `uv venv env`
 2. Run `source env/bin/activate` (activates the virtual environment)
 3. Run `python3 -m pip install -e ".[test]"` (installs the package in develop mode, along with test dependencies)
-    * or `uv pip install -e ".[test]"`
 4. Run `make test`
   1. To run a specific test do `pytest -k test_no_api_key`
 

example.py

@@ -1,15 +1,10 @@
 # PostHog Python library example
-import argparse
+
+# Import the library
+# import time
 
 import posthog
 
-# Add argument parsing
-parser = argparse.ArgumentParser(description="PostHog Python library example")
-parser.add_argument(
-    "--flag", default="person-on-events-enabled", help="Feature flag key to check (default: person-on-events-enabled)"
-)
-args = parser.parse_args()
-
 posthog.debug = True
 
 # You can find this key on the /setup page in PostHog
@@ -23,7 +18,7 @@ posthog.poll_interval = 10
 
 print(
     posthog.feature_enabled(
-        args.flag,  # Use the flag from command line arguments
+        "person-on-events-enabled",
         "12345",
         groups={"organization": str("0182ee91-8ef7-0000-4cb9-fedc5f00926a")},
         group_properties={
@@ -101,7 +96,6 @@ print(
         "distinct_id_random_22", person_properties={"$geoip_city_name": "Sydney"}, only_evaluate_locally=True
     )
 )
-print(posthog.get_remote_config_payload("encrypted_payload_flag_key"))
 
 
 posthog.shutdown()

llm_observability_examples.py

@@ -0,0 +1,196 @@
+import os
+import uuid
+
+import posthog
+from posthog.ai.openai import AsyncOpenAI, OpenAI
+
+# Example credentials - replace these with your own or use environment variables
+posthog.project_api_key = os.getenv("POSTHOG_PROJECT_API_KEY", "your-project-api-key")
+posthog.personal_api_key = os.getenv("POSTHOG_PERSONAL_API_KEY", "your-personal-api-key")
+posthog.host = os.getenv("POSTHOG_HOST", "http://localhost:8000")  # Or https://app.posthog.com
+posthog.debug = True
+# change this to False to see usage events
+# posthog.privacy_mode = True
+
+openai_client = OpenAI(
+    api_key=os.getenv("OPENAI_API_KEY", "your-openai-api-key"),
+    posthog_client=posthog,
+)
+
+async_openai_client = AsyncOpenAI(
+    api_key=os.getenv("OPENAI_API_KEY", "your-openai-api-key"),
+    posthog_client=posthog,
+)
+
+
+def main_sync():
+    trace_id = str(uuid.uuid4())
+    print("Trace ID:", trace_id)
+    distinct_id = "test2_distinct_id"
+    properties = {"test_property": "test_value"}
+    groups = {"company": "test_company"}
+
+    try:
+        basic_openai_call(distinct_id, trace_id, properties, groups)
+        streaming_openai_call(distinct_id, trace_id, properties, groups)
+        embedding_openai_call(distinct_id, trace_id, properties, groups)
+        image_openai_call()
+    except Exception as e:
+        print("Error during OpenAI call:", str(e))
+
+
+async def main_async():
+    trace_id = str(uuid.uuid4())
+    print("Trace ID:", trace_id)
+    distinct_id = "test_distinct_id"
+    properties = {"test_property": "test_value"}
+    groups = {"company": "test_company"}
+
+    try:
+        await basic_async_openai_call(distinct_id, trace_id, properties, groups)
+        await streaming_async_openai_call(distinct_id, trace_id, properties, groups)
+        await embedding_async_openai_call(distinct_id, trace_id, properties, groups)
+        await image_async_openai_call()
+    except Exception as e:
+        print("Error during OpenAI call:", str(e))
+
+
+def basic_openai_call(distinct_id, trace_id, properties, groups):
+    response = openai_client.chat.completions.create(
+        model="gpt-4o-mini",
+        messages=[
+            {"role": "system", "content": "You are a complex problem solver."},
+            {"role": "user", "content": "Explain quantum computing in simple terms."},
+        ],
+        max_tokens=100,
+        temperature=0.7,
+        posthog_distinct_id=distinct_id,
+        posthog_trace_id=trace_id,
+        posthog_properties=properties,
+        posthog_groups=groups,
+    )
+    print(response)
+    if response and response.choices:
+        print("OpenAI response:", response.choices[0].message.content)
+    else:
+        print("No response or unexpected format returned.")
+    return response
+
+
+async def basic_async_openai_call(distinct_id, trace_id, properties, groups):
+    response = await async_openai_client.chat.completions.create(
+        model="gpt-4o-mini",
+        messages=[
+            {"role": "system", "content": "You are a complex problem solver."},
+            {"role": "user", "content": "Explain quantum computing in simple terms."},
+        ],
+        max_tokens=100,
+        temperature=0.7,
+        posthog_distinct_id=distinct_id,
+        posthog_trace_id=trace_id,
+        posthog_properties=properties,
+        posthog_groups=groups,
+    )
+    if response and hasattr(response, "choices"):
+        print("OpenAI response:", response.choices[0].message.content)
+    else:
+        print("No response or unexpected format returned.")
+    return response
+
+
+def streaming_openai_call(distinct_id, trace_id, properties, groups):
+
+    response = openai_client.chat.completions.create(
+        model="gpt-4o-mini",
+        messages=[
+            {"role": "system", "content": "You are a complex problem solver."},
+            {"role": "user", "content": "Explain quantum computing in simple terms."},
+        ],
+        max_tokens=100,
+        temperature=0.7,
+        stream=True,
+        posthog_distinct_id=distinct_id,
+        posthog_trace_id=trace_id,
+        posthog_properties=properties,
+        posthog_groups=groups,
+    )
+
+    for chunk in response:
+        if hasattr(chunk, "choices") and chunk.choices and len(chunk.choices) > 0:
+            print(chunk.choices[0].delta.content or "", end="")
+
+    return response
+
+
+async def streaming_async_openai_call(distinct_id, trace_id, properties, groups):
+    response = await async_openai_client.chat.completions.create(
+        model="gpt-4o-mini",
+        messages=[
+            {"role": "system", "content": "You are a complex problem solver."},
+            {"role": "user", "content": "Explain quantum computing in simple terms."},
+        ],
+        max_tokens=100,
+        temperature=0.7,
+        stream=True,
+        posthog_distinct_id=distinct_id,
+        posthog_trace_id=trace_id,
+        posthog_properties=properties,
+        posthog_groups=groups,
+    )
+
+    async for chunk in response:
+        if hasattr(chunk, "choices") and chunk.choices and len(chunk.choices) > 0:
+            print(chunk.choices[0].delta.content or "", end="")
+
+    return response
+
+
+# none instrumented
+def image_openai_call():
+    response = openai_client.images.generate(model="dall-e-3", prompt="A cute baby hedgehog", n=1, size="1024x1024")
+    print(response)
+    return response
+
+
+# none instrumented
+async def image_async_openai_call():
+    response = await async_openai_client.images.generate(
+        model="dall-e-3", prompt="A cute baby hedgehog", n=1, size="1024x1024"
+    )
+    print(response)
+    return response
+
+
+def embedding_openai_call(posthog_distinct_id, posthog_trace_id, posthog_properties, posthog_groups):
+    response = openai_client.embeddings.create(
+        input="The hedgehog is cute",
+        model="text-embedding-3-small",
+        posthog_distinct_id=posthog_distinct_id,
+        posthog_trace_id=posthog_trace_id,
+        posthog_properties=posthog_properties,
+        posthog_groups=posthog_groups,
+    )
+    print(response)
+    return response
+
+
+async def embedding_async_openai_call(posthog_distinct_id, posthog_trace_id, posthog_properties, posthog_groups):
+    response = await async_openai_client.embeddings.create(
+        input="The hedgehog is cute",
+        model="text-embedding-3-small",
+        posthog_distinct_id=posthog_distinct_id,
+        posthog_trace_id=posthog_trace_id,
+        posthog_properties=posthog_properties,
+        posthog_groups=posthog_groups,
+    )
+    print(response)
+    return response
+
+
+# HOW TO RUN:
+# comment out one of these to run the other
+
+if __name__ == "__main__":
+    main_sync()
+
+# asyncio.run(main_async())

mypy-baseline.txt

@@ -1,55 +0,0 @@
-posthog/utils.py:0: error: Library stubs not installed for "six"  [import-untyped]
-posthog/utils.py:0: error: Library stubs not installed for "dateutil.tz"  [import-untyped]
-posthog/utils.py:0: error: Statement is unreachable  [unreachable]
-posthog/utils.py:0: error: Argument 1 to "join" of "str" has incompatible type "AttributeError"; expected "Iterable[str]"  [arg-type]
-posthog/request.py:0: error: Library stubs not installed for "requests"  [import-untyped]
-posthog/request.py:0: note: Hint: "python3 -m pip install types-requests"
-posthog/request.py:0: error: Library stubs not installed for "dateutil.tz"  [import-untyped]
-posthog/request.py:0: error: Incompatible types in assignment (expression has type "bytes", variable has type "str")  [assignment]
-posthog/consumer.py:0: error: Name "Empty" already defined (possibly by an import)  [no-redef]
-posthog/consumer.py:0: error: Need type annotation for "items" (hint: "items: list[<type>] = ...")  [var-annotated]
-posthog/consumer.py:0: error: Unsupported operand types for <= ("int" and "str")  [operator]
-posthog/consumer.py:0: note: Right operand is of type "int | str"
-posthog/consumer.py:0: error: Unsupported operand types for < ("str" and "int")  [operator]
-posthog/consumer.py:0: note: Left operand is of type "int | str"
-posthog/feature_flags.py:0: error: Library stubs not installed for "dateutil"  [import-untyped]
-posthog/feature_flags.py:0: error: Library stubs not installed for "dateutil.relativedelta"  [import-untyped]
-posthog/feature_flags.py:0: error: Unused "type: ignore" comment  [unused-ignore]
-posthog/client.py:0: error: Library stubs not installed for "dateutil.tz"  [import-untyped]
-posthog/client.py:0: note: Hint: "python3 -m pip install types-python-dateutil"
-posthog/client.py:0: note: (or run "mypy --install-types" to install all missing stub packages)
-posthog/client.py:0: note: See https://mypy.readthedocs.io/en/stable/running_mypy.html#missing-imports
-posthog/client.py:0: error: Library stubs not installed for "six"  [import-untyped]
-posthog/client.py:0: note: Hint: "python3 -m pip install types-six"
-posthog/client.py:0: error: Name "queue" already defined (by an import)  [no-redef]
-posthog/client.py:0: error: Need type annotation for "queue"  [var-annotated]
-posthog/client.py:0: error: Item "None" of "Any | None" has no attribute "get"  [union-attr]
-simulator.py:0: error: Unexpected keyword argument "anonymous_id" for "capture"  [call-arg]
-posthog/__init__.py:0: note: "capture" defined here
-simulator.py:0: error: Unexpected keyword argument "anonymous_id" for "identify"  [call-arg]
-posthog/__init__.py:0: note: "identify" defined here
-simulator.py:0: error: Unexpected keyword argument "traits" for "identify"  [call-arg]
-posthog/__init__.py:0: note: "identify" defined here
-example.py:0: error: Statement is unreachable  [unreachable]
-posthog/sentry/posthog_integration.py:0: error: Statement is unreachable  [unreachable]
-posthog/ai/utils.py:0: error: Need type annotation for "output" (hint: "output: list[<type>] = ...")  [var-annotated]
-posthog/ai/utils.py:0: error: Function "builtins.any" is not valid as a type  [valid-type]
-posthog/ai/utils.py:0: note: Perhaps you meant "typing.Any" instead of "any"?
-posthog/ai/utils.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/utils.py:0: error: Function "builtins.any" is not valid as a type  [valid-type]
-posthog/ai/utils.py:0: note: Perhaps you meant "typing.Any" instead of "any"?
-posthog/ai/utils.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-sentry_django_example/sentry_django_example/settings.py:0: error: Need type annotation for "ALLOWED_HOSTS" (hint: "ALLOWED_HOSTS: list[<type>] = ...")  [var-annotated]
-sentry_django_example/sentry_django_example/settings.py:0: error: Incompatible types in assignment (expression has type "str", variable has type "None")  [assignment]
-posthog/ai/openai/openai_async.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/openai/openai_async.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/openai/openai_async.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/openai/openai.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/openai/openai.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/openai/openai.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/anthropic/anthropic_async.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/anthropic/anthropic_async.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/anthropic/anthropic_async.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/anthropic/anthropic.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/anthropic/anthropic.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]
-posthog/ai/anthropic/anthropic.py:0: error: Incompatible types in assignment (expression has type "UUID", variable has type "str | None")  [assignment]

mypy.ini

@@ -1,38 +0,0 @@
-[mypy]
-python_version = 3.11
-plugins =
-    pydantic.mypy
-strict_optional = True
-no_implicit_optional = True
-warn_unused_ignores = True
-check_untyped_defs = True
-warn_unreachable = True
-strict_equality = True
-ignore_missing_imports = True
-
-[mypy-django.*]
-ignore_missing_imports = True
-
-[mypy-sentry_sdk.*]
-ignore_missing_imports = True
-
-[mypy-posthog.test.*]
-ignore_errors = True
-
-[mypy-posthog.*.test.*]
-ignore_errors = True
-
-[mypy-openai.*]
-ignore_missing_imports = True
-
-[mypy-langchain.*]
-ignore_missing_imports = True
-
-[mypy-langchain_core.*]
-ignore_missing_imports = True
-
-[mypy-anthropic.*]
-ignore_missing_imports = True
-
-[mypy-httpx.*]
-ignore_missing_imports = True

posthog/__init__.py

@@ -1,5 +1,4 @@
 import datetime  # noqa: F401
-import warnings
 from typing import Callable, Dict, List, Optional, Tuple  # noqa: F401
 
 from posthog.client import Client
@@ -37,7 +36,6 @@ def capture(
     distinct_id,  # type: str
     event,  # type: str
     properties=None,  # type: Optional[Dict]
-    context=None,  # type: Optional[Dict]
     timestamp=None,  # type: Optional[datetime.datetime]
     uuid=None,  # type: Optional[str]
     groups=None,  # type: Optional[Dict]
@@ -65,20 +63,11 @@ def capture(
     posthog.capture('distinct id', 'purchase', groups={'company': 'id:5'})
     ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "capture",
         distinct_id=distinct_id,
         event=event,
         properties=properties,
-        context=context,
         timestamp=timestamp,
         uuid=uuid,
         groups=groups,
@@ -90,7 +79,6 @@ def capture(
 def identify(
     distinct_id,  # type: str
     properties=None,  # type: Optional[Dict]
-    context=None,  # type: Optional[Dict]
     timestamp=None,  # type: Optional[datetime.datetime]
     uuid=None,  # type: Optional[str]
     disable_geoip=None,  # type: Optional[bool]
@@ -111,19 +99,10 @@ def identify(
     })
     ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "identify",
         distinct_id=distinct_id,
         properties=properties,
-        context=context,
         timestamp=timestamp,
         uuid=uuid,
         disable_geoip=disable_geoip,
@@ -133,7 +112,6 @@ def identify(
 def set(
     distinct_id,  # type: str
     properties=None,  # type: Optional[Dict]
-    context=None,  # type: Optional[Dict]
     timestamp=None,  # type: Optional[datetime.datetime]
     uuid=None,  # type: Optional[str]
     disable_geoip=None,  # type: Optional[bool]
@@ -154,19 +132,10 @@ def set(
      })
      ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "set",
         distinct_id=distinct_id,
         properties=properties,
-        context=context,
         timestamp=timestamp,
         uuid=uuid,
         disable_geoip=disable_geoip,
@@ -176,7 +145,6 @@ def set(
 def set_once(
     distinct_id,  # type: str
     properties=None,  # type: Optional[Dict]
-    context=None,  # type: Optional[Dict]
     timestamp=None,  # type: Optional[datetime.datetime]
     uuid=None,  # type: Optional[str]
     disable_geoip=None,  # type: Optional[bool]
@@ -197,19 +165,10 @@ def set_once(
      })
      ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "set_once",
         distinct_id=distinct_id,
         properties=properties,
-        context=context,
         timestamp=timestamp,
         uuid=uuid,
         disable_geoip=disable_geoip,
@@ -220,7 +179,6 @@ def group_identify(
     group_type,  # type: str
     group_key,  # type: str
     properties=None,  # type: Optional[Dict]
-    context=None,  # type: Optional[Dict]
     timestamp=None,  # type: Optional[datetime.datetime]
     uuid=None,  # type: Optional[str]
     disable_geoip=None,  # type: Optional[bool]
@@ -241,20 +199,11 @@ def group_identify(
      })
      ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "group_identify",
         group_type=group_type,
         group_key=group_key,
         properties=properties,
-        context=context,
         timestamp=timestamp,
         uuid=uuid,
         disable_geoip=disable_geoip,
@@ -264,7 +213,6 @@ def group_identify(
 def alias(
     previous_id,  # type: str
     distinct_id,  # type: str
-    context=None,  # type: Optional[Dict]
     timestamp=None,  # type: Optional[datetime.datetime]
     uuid=None,  # type: Optional[str]
     disable_geoip=None,  # type: Optional[bool]
@@ -286,19 +234,10 @@ def alias(
     posthog.alias('anonymous session id', 'distinct id')
     ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "alias",
         previous_id=previous_id,
         distinct_id=distinct_id,
-        context=context,
         timestamp=timestamp,
         uuid=uuid,
         disable_geoip=disable_geoip,
@@ -337,14 +276,6 @@ def capture_exception(
 
     ```
     """
-
-    if context is not None:
-        warnings.warn(
-            "The 'context' parameter is deprecated and will be removed in a future version.",
-            DeprecationWarning,
-            stacklevel=2,
-        )
-
     return _proxy(
         "capture_exception",
         exception=exception,
@@ -492,26 +423,6 @@ def get_feature_flag_payload(
     )
 
 
-def get_remote_config_payload(
-    key,  # type: str
-):
-    """Get the payload for a remote config feature flag.
-
-    Args:
-        key: The key of the feature flag
-
-    Returns:
-        The payload associated with the feature flag. If payload is encrypted, the return value will decrypted
-
-    Note:
-        Requires personal_api_key to be set for authentication
-    """
-    return _proxy(
-        "get_remote_config_payload",
-        key=key,
-    )
-
-
 def get_all_flags_and_payloads(
     distinct_id,
     groups={},

posthog/ai/anthropic/anthropic.py

@@ -125,8 +125,6 @@ class WrappedMessages(Messages):
                             for k in [
                                 "input_tokens",
                                 "output_tokens",
-                                "cache_read_input_tokens",
-                                "cache_creation_input_tokens",
                             ]
                         }
 
@@ -186,8 +184,6 @@ class WrappedMessages(Messages):
             "$ai_http_status": 200,
             "$ai_input_tokens": usage_stats.get("input_tokens", 0),
             "$ai_output_tokens": usage_stats.get("output_tokens", 0),
-            "$ai_cache_read_input_tokens": usage_stats.get("cache_read_input_tokens", 0),
-            "$ai_cache_creation_input_tokens": usage_stats.get("cache_creation_input_tokens", 0),
             "$ai_latency": latency,
             "$ai_trace_id": posthog_trace_id,
             "$ai_base_url": str(self._client.base_url),

posthog/ai/anthropic/anthropic_async.py

@@ -125,8 +125,6 @@ class AsyncWrappedMessages(AsyncMessages):
                             for k in [
                                 "input_tokens",
                                 "output_tokens",
-                                "cache_read_input_tokens",
-                                "cache_creation_input_tokens",
                             ]
                         }
 
@@ -186,8 +184,6 @@ class AsyncWrappedMessages(AsyncMessages):
             "$ai_http_status": 200,
             "$ai_input_tokens": usage_stats.get("input_tokens", 0),
             "$ai_output_tokens": usage_stats.get("output_tokens", 0),
-            "$ai_cache_read_input_tokens": usage_stats.get("cache_read_input_tokens", 0),
-            "$ai_cache_creation_input_tokens": usage_stats.get("cache_creation_input_tokens", 0),
             "$ai_latency": latency,
             "$ai_trace_id": posthog_trace_id,
             "$ai_base_url": str(self._client.base_url),

posthog/ai/langchain/callbacks.py

@@ -60,8 +60,6 @@ class GenerationMetadata(SpanMetadata):
     """Model parameters of the run: temperature, max_tokens, etc."""
     base_url: Optional[str] = None
     """Base URL of the provider's API used in the run."""
-    tools: Optional[List[Dict[str, Any]]] = None
-    """Tools provided to the model."""
 
 
 RunMetadata = Union[SpanMetadata, GenerationMetadata]
@@ -241,7 +239,6 @@ class CallbackHandler(BaseCallbackHandler):
         **kwargs: Any,
     ) -> Any:
         self._log_debug_event("on_tool_start", run_id, parent_run_id, input_str=input_str)
-        self._set_parent_of_run(run_id, parent_run_id)
         self._set_trace_or_span_metadata(serialized, input_str, run_id, parent_run_id, **kwargs)
 
     def on_tool_end(
@@ -278,7 +275,6 @@ class CallbackHandler(BaseCallbackHandler):
         **kwargs: Any,
     ) -> Any:
         self._log_debug_event("on_retriever_start", run_id, parent_run_id, query=query)
-        self._set_parent_of_run(run_id, parent_run_id)
         self._set_trace_or_span_metadata(serialized, query, run_id, parent_run_id, **kwargs)
 
     def on_retriever_end(
@@ -379,8 +375,6 @@ class CallbackHandler(BaseCallbackHandler):
         generation = GenerationMetadata(name=run_name, input=messages, start_time=time.time(), end_time=None)
         if isinstance(invocation_params, dict):
             generation.model_params = get_model_params(invocation_params)
-            if tools := invocation_params.get("tools"):
-                generation.tools = tools
         if isinstance(metadata, dict):
             if model := metadata.get("ls_model_name"):
                 generation.model = model
@@ -428,11 +422,7 @@ class CallbackHandler(BaseCallbackHandler):
             log.warning(f"Run {run_id} is a generation, but attempted to be captured as a trace or span.")
             return
         self._capture_trace_or_span(
-            trace_id,
-            run_id,
-            run,
-            outputs,
-            self._get_parent_run_id(trace_id, run_id, parent_run_id),
+            trace_id, run_id, run, outputs, self._get_parent_run_id(trace_id, run_id, parent_run_id)
         )
 
     def _capture_trace_or_span(
@@ -473,10 +463,7 @@ class CallbackHandler(BaseCallbackHandler):
         )
 
     def _pop_run_and_capture_generation(
-        self,
-        run_id: UUID,
-        parent_run_id: Optional[UUID],
-        response: Union[LLMResult, BaseException],
+        self, run_id: UUID, parent_run_id: Optional[UUID], response: Union[LLMResult, BaseException]
     ):
         trace_id = self._get_trace_id(run_id)
         self._pop_parent_of_run(run_id)
@@ -487,11 +474,7 @@ class CallbackHandler(BaseCallbackHandler):
             log.warning(f"Run {run_id} is not a generation, but attempted to be captured as a generation.")
             return
         self._capture_generation(
-            trace_id,
-            run_id,
-            run,
-            response,
-            self._get_parent_run_id(trace_id, run_id, parent_run_id),
+            trace_id, run_id, run, response, self._get_parent_run_id(trace_id, run_id, parent_run_id)
         )
 
     def _capture_generation(
@@ -515,12 +498,6 @@ class CallbackHandler(BaseCallbackHandler):
             "$ai_latency": run.latency,
             "$ai_base_url": run.base_url,
         }
-        if run.tools:
-            event_properties["$ai_tools"] = with_privacy_mode(
-                self._client,
-                self._privacy_mode,
-                run.tools,
-            )
 
         if isinstance(output, BaseException):
             event_properties["$ai_http_status"] = _get_http_status(output)
@@ -618,9 +595,6 @@ def _parse_usage_model(
         # Bedrock: https://docs.aws.amazon.com/bedrock/latest/userguide/monitoring-cw.html#runtime-cloudwatch-metrics
         ("inputTokenCount", "input"),
         ("outputTokenCount", "output"),
-        # Bedrock Anthropic
-        ("prompt_tokens", "input"),
-        ("completion_tokens", "output"),
         # langchain-ibm https://pypi.org/project/langchain-ibm/
         ("input_token_count", "input"),
         ("generated_token_count", "output"),
@@ -651,10 +625,6 @@ def _parse_usage(response: LLMResult):
 
     if hasattr(response, "generations"):
         for generation in response.generations:
-            if "usage" in generation:
-                llm_usage = _parse_usage_model(generation["usage"])
-                break
-
             for generation_chunk in generation:
                 if generation_chunk.generation_info and ("usage_metadata" in generation_chunk.generation_info):
                     llm_usage = _parse_usage_model(generation_chunk.generation_info["usage_metadata"])

posthog/ai/openai/__init__.py

@@ -1,5 +1,4 @@
 from .openai import OpenAI
 from .openai_async import AsyncOpenAI
-from .openai_providers import AsyncAzureOpenAI, AzureOpenAI
 
-__all__ = ["OpenAI", "AsyncOpenAI", "AzureOpenAI", "AsyncAzureOpenAI"]
+__all__ = ["OpenAI", "AsyncOpenAI"]

posthog/ai/openai/openai.py

@@ -1,6 +1,6 @@
 import time
 import uuid
-from typing import Any, Dict, List, Optional
+from typing import Any, Dict, Optional
 
 try:
     import openai
@@ -31,7 +31,6 @@ class OpenAI(openai.OpenAI):
         self._ph_client = posthog_client
         self.chat = WrappedChat(self)
         self.embeddings = WrappedEmbeddings(self)
-        self.beta = WrappedBeta(self)
 
 
 class WrappedChat(openai.resources.chat.Chat):
@@ -92,7 +91,6 @@ class WrappedCompletions(openai.resources.chat.completions.Completions):
         start_time = time.time()
         usage_stats: Dict[str, int] = {}
         accumulated_content = []
-        accumulated_tools = {}
         if "stream_options" not in kwargs:
             kwargs["stream_options"] = {}
         kwargs["stream_options"]["include_usage"] = True
@@ -101,8 +99,6 @@ class WrappedCompletions(openai.resources.chat.completions.Completions):
         def generator():
             nonlocal usage_stats
             nonlocal accumulated_content
-            nonlocal accumulated_tools
-
             try:
                 for chunk in response:
                     if hasattr(chunk, "usage") and chunk.usage:
@@ -115,36 +111,17 @@ class WrappedCompletions(openai.resources.chat.completions.Completions):
                             ]
                         }
 
-                        # Add support for cached tokens
-                        if hasattr(chunk.usage, "prompt_tokens_details") and hasattr(
-                            chunk.usage.prompt_tokens_details, "cached_tokens"
-                        ):
-                            usage_stats["cache_read_input_tokens"] = chunk.usage.prompt_tokens_details.cached_tokens
-
                     if hasattr(chunk, "choices") and chunk.choices and len(chunk.choices) > 0:
                         content = chunk.choices[0].delta.content
                         if content:
                             accumulated_content.append(content)
 
-                        # Process tool calls
-                        tool_calls = getattr(chunk.choices[0].delta, "tool_calls", None)
-                        if tool_calls:
-                            for tool_call in tool_calls:
-                                index = tool_call.index
-                                if index not in accumulated_tools:
-                                    accumulated_tools[index] = tool_call
-                                else:
-                                    # Append arguments for existing tool calls
-                                    if hasattr(tool_call, "function") and hasattr(tool_call.function, "arguments"):
-                                        accumulated_tools[index].function.arguments += tool_call.function.arguments
-
                     yield chunk
 
             finally:
                 end_time = time.time()
                 latency = end_time - start_time
                 output = "".join(accumulated_content)
-                tools = list(accumulated_tools.values()) if accumulated_tools else None
                 self._capture_streaming_event(
                     posthog_distinct_id,
                     posthog_trace_id,
@@ -155,7 +132,6 @@ class WrappedCompletions(openai.resources.chat.completions.Completions):
                     usage_stats,
                     latency,
                     output,
-                    tools,
                 )
 
         return generator()
@@ -171,7 +147,6 @@ class WrappedCompletions(openai.resources.chat.completions.Completions):
         usage_stats: Dict[str, int],
         latency: float,
         output: str,
-        tool_calls: Optional[List[Dict[str, Any]]] = None,
     ):
         if posthog_trace_id is None:
             posthog_trace_id = uuid.uuid4()
@@ -189,20 +164,12 @@ class WrappedCompletions(openai.resources.chat.completions.Completions):
             "$ai_http_status": 200,
             "$ai_input_tokens": usage_stats.get("prompt_tokens", 0),
             "$ai_output_tokens": usage_stats.get("completion_tokens", 0),
-            "$ai_cache_read_input_tokens": usage_stats.get("cache_read_input_tokens", 0),
             "$ai_latency": latency,
             "$ai_trace_id": posthog_trace_id,
             "$ai_base_url": str(self._client.base_url),
-            **(posthog_properties or {}),
+            **posthog_properties,
         }
 
-        if tool_calls:
-            event_properties["$ai_tools"] = with_privacy_mode(
-                self._client._ph_client,
-                posthog_privacy_mode,
-                tool_calls,
-            )
-
         if posthog_distinct_id is None:
             event_properties["$process_person_profile"] = False
 
@@ -266,7 +233,7 @@ class WrappedEmbeddings(openai.resources.embeddings.Embeddings):
             "$ai_latency": latency,
             "$ai_trace_id": posthog_trace_id,
             "$ai_base_url": str(self._client.base_url),
-            **(posthog_properties or {}),
+            **posthog_properties,
         }
 
         if posthog_distinct_id is None:
@@ -282,45 +249,3 @@ class WrappedEmbeddings(openai.resources.embeddings.Embeddings):
             )
 
         return response
-
-
-class WrappedBeta(openai.resources.beta.Beta):
-    _client: OpenAI
-
-    @property
-    def chat(self):
-        return WrappedBetaChat(self._client)
-
-
-class WrappedBetaChat(openai.resources.beta.chat.Chat):
-    _client: OpenAI
-
-    @property
-    def completions(self):
-        return WrappedBetaCompletions(self._client)
-
-
-class WrappedBetaCompletions(openai.resources.beta.chat.completions.Completions):
-    _client: OpenAI
-
-    def parse(
-        self,
-        posthog_distinct_id: Optional[str] = None,
-        posthog_trace_id: Optional[str] = None,
-        posthog_properties: Optional[Dict[str, Any]] = None,
-        posthog_privacy_mode: bool = False,
-        posthog_groups: Optional[Dict[str, Any]] = None,
-        **kwargs: Any,
-    ):
-        return call_llm_and_track_usage(
-            posthog_distinct_id,
-            self._client._ph_client,
-            "openai",
-            posthog_trace_id,
-            posthog_properties,
-            posthog_privacy_mode,
-            posthog_groups,
-            self._client.base_url,
-            super().parse,
-            **kwargs,
-        )

posthog/ai/openai/openai_async.py

@@ -1,6 +1,6 @@
 import time
 import uuid
-from typing import Any, Dict, List, Optional
+from typing import Any, Dict, Optional
 
 try:
     import openai
@@ -30,7 +30,6 @@ class AsyncOpenAI(openai.AsyncOpenAI):
         self._ph_client = posthog_client
         self.chat = WrappedChat(self)
         self.embeddings = WrappedEmbeddings(self)
-        self.beta = WrappedBeta(self)
 
 
 class WrappedChat(openai.resources.chat.AsyncChat):
@@ -73,8 +72,6 @@ class WrappedCompletions(openai.resources.chat.completions.AsyncCompletions):
             "openai",
             posthog_trace_id,
             posthog_properties,
-            posthog_privacy_mode,
-            posthog_groups,
             self._client.base_url,
             super().create,
             **kwargs,
@@ -93,14 +90,13 @@ class WrappedCompletions(openai.resources.chat.completions.AsyncCompletions):
         start_time = time.time()
         usage_stats: Dict[str, int] = {}
         accumulated_content = []
-        accumulated_tools = {}
         if "stream_options" not in kwargs:
             kwargs["stream_options"] = {}
         kwargs["stream_options"]["include_usage"] = True
         response = await super().create(**kwargs)
 
         async def async_generator():
-            nonlocal usage_stats, accumulated_content, accumulated_tools
+            nonlocal usage_stats, accumulated_content
             try:
                 async for chunk in response:
                     if hasattr(chunk, "usage") and chunk.usage:
@@ -112,37 +108,17 @@ class WrappedCompletions(openai.resources.chat.completions.AsyncCompletions):
                                 "total_tokens",
                             ]
                         }
-
-                        # Add support for cached tokens
-                        if hasattr(chunk.usage, "prompt_tokens_details") and hasattr(
-                            chunk.usage.prompt_tokens_details, "cached_tokens"
-                        ):
-                            usage_stats["cache_read_input_tokens"] = chunk.usage.prompt_tokens_details.cached_tokens
-
                     if hasattr(chunk, "choices") and chunk.choices and len(chunk.choices) > 0:
                         content = chunk.choices[0].delta.content
                         if content:
                             accumulated_content.append(content)
 
-                        # Process tool calls
-                        tool_calls = getattr(chunk.choices[0].delta, "tool_calls", None)
-                        if tool_calls:
-                            for tool_call in tool_calls:
-                                index = tool_call.index
-                                if index not in accumulated_tools:
-                                    accumulated_tools[index] = tool_call
-                                else:
-                                    # Append arguments for existing tool calls
-                                    if hasattr(tool_call, "function") and hasattr(tool_call.function, "arguments"):
-                                        accumulated_tools[index].function.arguments += tool_call.function.arguments
-
                     yield chunk
 
             finally:
                 end_time = time.time()
                 latency = end_time - start_time
                 output = "".join(accumulated_content)
-                tools = list(accumulated_tools.values()) if accumulated_tools else None
                 await self._capture_streaming_event(
                     posthog_distinct_id,
                     posthog_trace_id,
@@ -153,7 +129,6 @@ class WrappedCompletions(openai.resources.chat.completions.AsyncCompletions):
                     usage_stats,
                     latency,
                     output,
-                    tools,
                 )
 
         return async_generator()
@@ -169,7 +144,6 @@ class WrappedCompletions(openai.resources.chat.completions.AsyncCompletions):
         usage_stats: Dict[str, int],
         latency: float,
         output: str,
-        tool_calls: Optional[List[Dict[str, Any]]] = None,
     ):
         if posthog_trace_id is None:
             posthog_trace_id = uuid.uuid4()
@@ -187,20 +161,12 @@ class WrappedCompletions(openai.resources.chat.completions.AsyncCompletions):
             "$ai_http_status": 200,
             "$ai_input_tokens": usage_stats.get("prompt_tokens", 0),
             "$ai_output_tokens": usage_stats.get("completion_tokens", 0),
-            "$ai_cache_read_input_tokens": usage_stats.get("cache_read_input_tokens", 0),
             "$ai_latency": latency,
             "$ai_trace_id": posthog_trace_id,
             "$ai_base_url": str(self._client.base_url),
-            **(posthog_properties or {}),
+            **posthog_properties,
         }
 
-        if tool_calls:
-            event_properties["$ai_tools"] = with_privacy_mode(
-                self._client._ph_client,
-                posthog_privacy_mode,
-                tool_calls,
-            )
-
         if posthog_distinct_id is None:
             event_properties["$process_person_profile"] = False
 
@@ -266,7 +232,7 @@ class WrappedEmbeddings(openai.resources.embeddings.AsyncEmbeddings):
             "$ai_latency": latency,
             "$ai_trace_id": posthog_trace_id,
             "$ai_base_url": str(self._client.base_url),
-            **(posthog_properties or {}),
+            **posthog_properties,
         }
 
         if posthog_distinct_id is None:
@@ -282,45 +248,3 @@ class WrappedEmbeddings(openai.resources.embeddings.AsyncEmbeddings):
             )
 
         return response
-
-
-class WrappedBeta(openai.resources.beta.AsyncBeta):
-    _client: AsyncOpenAI
-
-    @property
-    def chat(self):
-        return WrappedBetaChat(self._client)
-
-
-class WrappedBetaChat(openai.resources.beta.chat.AsyncChat):
-    _client: AsyncOpenAI
-
-    @property
-    def completions(self):
-        return WrappedBetaCompletions(self._client)
-
-
-class WrappedBetaCompletions(openai.resources.beta.chat.completions.AsyncCompletions):
-    _client: AsyncOpenAI
-
-    async def parse(
-        self,
-        posthog_distinct_id: Optional[str] = None,
-        posthog_trace_id: Optional[str] = None,
-        posthog_properties: Optional[Dict[str, Any]] = None,
-        posthog_privacy_mode: bool = False,
-        posthog_groups: Optional[Dict[str, Any]] = None,
-        **kwargs: Any,
-    ):
-        return await call_llm_and_track_usage_async(
-            posthog_distinct_id,
-            self._client._ph_client,
-            "openai",
-            posthog_trace_id,
-            posthog_properties,
-            posthog_privacy_mode,
-            posthog_groups,
-            self._client.base_url,
-            super().parse,
-            **kwargs,
-        )

posthog/ai/openai/openai_providers.py

@@ -1,41 +0,0 @@
-try:
-    import openai
-    import openai.resources
-except ImportError:
-    raise ModuleNotFoundError("Please install the Open AI SDK to use this feature: 'pip install openai'")
-
-from posthog.ai.openai.openai import WrappedBeta, WrappedChat, WrappedEmbeddings
-from posthog.ai.openai.openai_async import WrappedBeta as AsyncWrappedBeta
-from posthog.ai.openai.openai_async import WrappedChat as AsyncWrappedChat
-from posthog.ai.openai.openai_async import WrappedEmbeddings as AsyncWrappedEmbeddings
-from posthog.client import Client as PostHogClient
-
-
-class AzureOpenAI(openai.AzureOpenAI):
-    """
-    A wrapper around the Azure OpenAI SDK that automatically sends LLM usage events to PostHog.
-    """
-
-    _ph_client: PostHogClient
-
-    def __init__(self, posthog_client: PostHogClient, **kwargs):
-        super().__init__(**kwargs)
-        self._ph_client = posthog_client
-        self.chat = WrappedChat(self)
-        self.embeddings = WrappedEmbeddings(self)
-        self.beta = WrappedBeta(self)
-
-
-class AsyncAzureOpenAI(openai.AsyncAzureOpenAI):
-    """
-    A wrapper around the Azure OpenAI SDK that automatically sends LLM usage events to PostHog.
-    """
-
-    _ph_client: PostHogClient
-
-    def __init__(self, posthog_client: PostHogClient, **kwargs):
-        super().__init__(**kwargs)
-        self._ph_client = posthog_client
-        self.chat = AsyncWrappedChat(self)
-        self.embeddings = AsyncWrappedEmbeddings(self)
-        self.beta = AsyncWrappedBeta(self)

posthog/ai/utils.py

@@ -34,25 +34,15 @@ def get_usage(response, provider: str) -> Dict[str, Any]:
         return {
             "input_tokens": response.usage.input_tokens,
             "output_tokens": response.usage.output_tokens,
-            "cache_read_input_tokens": response.usage.cache_read_input_tokens,
-            "cache_creation_input_tokens": response.usage.cache_creation_input_tokens,
         }
     elif provider == "openai":
-        cached_tokens = 0
-        if hasattr(response.usage, "prompt_tokens_details") and hasattr(
-            response.usage.prompt_tokens_details, "cached_tokens"
-        ):
-            cached_tokens = response.usage.prompt_tokens_details.cached_tokens
         return {
             "input_tokens": response.usage.prompt_tokens,
             "output_tokens": response.usage.completion_tokens,
-            "cache_read_input_tokens": cached_tokens,
         }
     return {
         "input_tokens": 0,
         "output_tokens": 0,
-        "cache_read_input_tokens": 0,
-        "cache_creation_input_tokens": 0,
     }
 
 
@@ -96,21 +86,6 @@ def format_response_openai(response):
     return output
 
 
-def format_tool_calls(response, provider: str):
-    if provider == "anthropic":
-        if hasattr(response, "tools") and response.tools and len(response.tools) > 0:
-            return response.tools
-    elif provider == "openai":
-        if (
-            hasattr(response, "choices")
-            and response.choices
-            and hasattr(response.choices[0].message, "tool_calls")
-            and response.choices[0].message.tool_calls
-        ):
-            return response.choices[0].message.tool_calls
-    return None
-
-
 def merge_system_prompt(kwargs: Dict[str, Any], provider: str):
     if provider != "anthropic":
         return kwargs.get("messages")
@@ -182,16 +157,6 @@ def call_llm_and_track_usage(
             **(error_params or {}),
         }
 
-        tool_calls = format_tool_calls(response, provider)
-        if tool_calls:
-            event_properties["$ai_tools"] = with_privacy_mode(ph_client, posthog_privacy_mode, tool_calls)
-
-        if usage.get("cache_read_input_tokens") is not None and usage.get("cache_read_input_tokens", 0) > 0:
-            event_properties["$ai_cache_read_input_tokens"] = usage.get("cache_read_input_tokens", 0)
-
-        if usage.get("cache_creation_input_tokens") is not None and usage.get("cache_creation_input_tokens", 0) > 0:
-            event_properties["$ai_cache_creation_input_tokens"] = usage.get("cache_creation_input_tokens", 0)
-
         if posthog_distinct_id is None:
             event_properties["$process_person_profile"] = False
 
@@ -268,16 +233,6 @@ async def call_llm_and_track_usage_async(
             **(error_params or {}),
         }
 
-        tool_calls = format_tool_calls(response, provider)
-        if tool_calls:
-            event_properties["$ai_tools"] = with_privacy_mode(ph_client, posthog_privacy_mode, tool_calls)
-
-        if usage.get("cache_read_input_tokens") is not None and usage.get("cache_read_input_tokens", 0) > 0:
-            event_properties["$ai_cache_read_input_tokens"] = usage.get("cache_read_input_tokens", 0)
-
-        if usage.get("cache_creation_input_tokens") is not None and usage.get("cache_creation_input_tokens", 0) > 0:
-            event_properties["$ai_cache_creation_input_tokens"] = usage.get("cache_creation_input_tokens", 0)
-
         if posthog_distinct_id is None:
             event_properties["$process_person_profile"] = False
 

posthog/client.py

@@ -2,14 +2,10 @@ import atexit
 import logging
 import numbers
 import os
-import platform
 import sys
-import warnings
 from datetime import datetime, timedelta
-from typing import Any
 from uuid import UUID, uuid4
 
-import distro  # For Linux OS detection
 from dateutil.tz import tzutc
 from six import string_types
 
@@ -18,7 +14,7 @@ from posthog.exception_capture import ExceptionCapture
 from posthog.exception_utils import exc_info_from_error, exceptions_from_error_tuple, handle_in_app
 from posthog.feature_flags import InconclusiveMatchError, match_feature_flag_properties
 from posthog.poller import Poller
-from posthog.request import DEFAULT_HOST, APIError, batch_post, decide, determine_server_host, get, remote_config
+from posthog.request import DEFAULT_HOST, APIError, batch_post, decide, determine_server_host, get
 from posthog.utils import SizeLimitedDict, clean, guess_timezone, remove_trailing_slash
 from posthog.version import VERSION
 
@@ -32,60 +28,6 @@ ID_TYPES = (numbers.Number, string_types, UUID)
 MAX_DICT_SIZE = 50_000
 
 
-def get_os_info():
-    """
-    Returns standardized OS name and version information.
-    Similar to how user agent parsing works in JS.
-    """
-    os_name = ""
-    os_version = ""
-
-    platform_name = sys.platform
-
-    if platform_name.startswith("win"):
-        os_name = "Windows"
-        if hasattr(platform, "win32_ver"):
-            win_version = platform.win32_ver()[0]
-            if win_version:
-                os_version = win_version
-
-    elif platform_name == "darwin":
-        os_name = "Mac OS X"
-        if hasattr(platform, "mac_ver"):
-            mac_version = platform.mac_ver()[0]
-            if mac_version:
-                os_version = mac_version
-
-    elif platform_name.startswith("linux"):
-        os_name = "Linux"
-        linux_info = distro.info()
-        if linux_info["version"]:
-            os_version = linux_info["version"]
-
-    elif platform_name.startswith("freebsd"):
-        os_name = "FreeBSD"
-        if hasattr(platform, "release"):
-            os_version = platform.release()
-
-    else:
-        os_name = platform_name
-        if hasattr(platform, "release"):
-            os_version = platform.release()
-
-    return os_name, os_version
-
-
-def system_context() -> dict[str, Any]:
-    os_name, os_version = get_os_info()
-
-    return {
-        "$python_runtime": platform.python_implementation(),
-        "$python_version": "%s.%s.%s" % (sys.version_info[:3]),
-        "$os": os_name,
-        "$os_version": os_version,
-    }
-
-
 class Client(object):
     """Create a new PostHog client."""
 
@@ -204,14 +146,7 @@ class Client(object):
                 if send:
                     consumer.start()
 
-    def identify(self, distinct_id=None, properties=None, context=None, timestamp=None, uuid=None, disable_geoip=None):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
+    def identify(self, distinct_id=None, properties=None, timestamp=None, uuid=None, disable_geoip=None):
         properties = properties or {}
         require("distinct_id", distinct_id, ID_TYPES)
         require("properties", properties, dict)
@@ -274,22 +209,13 @@ class Client(object):
         distinct_id=None,
         event=None,
         properties=None,
-        context=None,
         timestamp=None,
         uuid=None,
         groups=None,
         send_feature_flags=False,
         disable_geoip=None,
     ):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
-        properties = {**(properties or {}), **system_context()}
-
+        properties = properties or {}
         require("distinct_id", distinct_id, ID_TYPES)
         require("properties", properties, dict)
         require("event", event, string_types)
@@ -314,7 +240,7 @@ class Client(object):
             except Exception as e:
                 self.log.exception(f"[FEATURE FLAGS] Unable to get feature variants: {e}")
 
-        elif self.feature_flags and event != "$feature_flag_called":
+        elif self.feature_flags:
             # Local evaluation is enabled, flags are loaded, so try and get all flags we can without going to the server
             feature_variants = self.get_all_flags(
                 distinct_id, groups=(groups or {}), disable_geoip=disable_geoip, only_evaluate_locally=True
@@ -332,14 +258,7 @@ class Client(object):
 
         return self._enqueue(msg, disable_geoip)
 
-    def set(self, distinct_id=None, properties=None, context=None, timestamp=None, uuid=None, disable_geoip=None):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
+    def set(self, distinct_id=None, properties=None, timestamp=None, uuid=None, disable_geoip=None):
         properties = properties or {}
         require("distinct_id", distinct_id, ID_TYPES)
         require("properties", properties, dict)
@@ -354,14 +273,7 @@ class Client(object):
 
         return self._enqueue(msg, disable_geoip)
 
-    def set_once(self, distinct_id=None, properties=None, context=None, timestamp=None, uuid=None, disable_geoip=None):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
+    def set_once(self, distinct_id=None, properties=None, timestamp=None, uuid=None, disable_geoip=None):
         properties = properties or {}
         require("distinct_id", distinct_id, ID_TYPES)
         require("properties", properties, dict)
@@ -381,18 +293,11 @@ class Client(object):
         group_type=None,
         group_key=None,
         properties=None,
-        context=None,
         timestamp=None,
         uuid=None,
         disable_geoip=None,
         distinct_id=None,
     ):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
         properties = properties or {}
         require("group_type", group_type, ID_TYPES)
         require("group_key", group_key, ID_TYPES)
@@ -417,14 +322,7 @@ class Client(object):
 
         return self._enqueue(msg, disable_geoip)
 
-    def alias(self, previous_id=None, distinct_id=None, context=None, timestamp=None, uuid=None, disable_geoip=None):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
+    def alias(self, previous_id=None, distinct_id=None, timestamp=None, uuid=None, disable_geoip=None):
         require("previous_id", previous_id, ID_TYPES)
         require("distinct_id", distinct_id, ID_TYPES)
 
@@ -440,17 +338,9 @@ class Client(object):
 
         return self._enqueue(msg, disable_geoip)
 
-    def page(
-        self, distinct_id=None, url=None, properties=None, context=None, timestamp=None, uuid=None, disable_geoip=None
-    ):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
+    def page(self, distinct_id=None, url=None, properties=None, timestamp=None, uuid=None, disable_geoip=None):
         properties = properties or {}
+
         require("distinct_id", distinct_id, ID_TYPES)
         require("properties", properties, dict)
 
@@ -477,13 +367,6 @@ class Client(object):
         uuid=None,
         groups=None,
     ):
-        if context is not None:
-            warnings.warn(
-                "The 'context' parameter is deprecated and will be removed in a future version.",
-                DeprecationWarning,
-                stacklevel=2,
-            )
-
         # this function shouldn't ever throw an error, so it logs exceptions instead of raising them.
         # this is important to ensure we don't unexpectedly re-raise exceptions in the user's code.
         try:
@@ -658,21 +541,6 @@ class Client(object):
                         "To use feature flags, please set a personal_api_key "
                         "More information: https://posthog.com/docs/api/overview",
                     )
-            elif e.status == 402:
-                self.log.warning(
-                    "[FEATURE FLAGS] PostHog feature flags quota limited, resetting feature flag data.  Learn more about billing limits at https://posthog.com/docs/billing/limits-alerts"
-                )
-                # Reset all feature flag data when quota limited
-                self.feature_flags = []
-                self.feature_flags_by_key = {}
-                self.group_type_mapping = {}
-                self.cohorts = {}
-
-                if self.debug:
-                    raise APIError(
-                        status=402,
-                        message="PostHog feature flags quota limited",
-                    )
             else:
                 self.log.error(f"[FEATURE FLAGS] Error loading feature flags: {e}")
         except Exception as e:
@@ -795,6 +663,7 @@ class Client(object):
             self.load_feature_flags()
         response = None
 
+        # If loading in previous line failed
         if self.feature_flags:
             for flag in self.feature_flags:
                 if flag["key"] == key:
@@ -813,7 +682,6 @@ class Client(object):
                     except Exception as e:
                         self.log.exception(f"[FEATURE FLAGS] Error while computing variant locally: {e}")
                         continue
-                    break
 
         flag_was_locally_evaluated = response is not None
         if not flag_was_locally_evaluated and not only_evaluate_locally:
@@ -895,7 +763,7 @@ class Client(object):
                     distinct_id, groups, person_properties, group_properties, disable_geoip
                 )
                 response = responses_and_payloads["featureFlags"].get(key, None)
-                payload = responses_and_payloads["featureFlagPayloads"].get(str(key), None)
+                payload = responses_and_payloads["featureFlagPayloads"].get(str(key).lower(), None)
             except Exception as e:
                 self.log.exception(f"[FEATURE FLAGS] Unable to get feature flags and payloads: {e}")
 
@@ -922,40 +790,16 @@ class Client(object):
 
         return payload
 
-    def get_remote_config_payload(self, key: str):
-        if self.disabled:
-            return None
-
-        if self.personal_api_key is None:
-            self.log.warning(
-                "[FEATURE FLAGS] You have to specify a personal_api_key to fetch decrypted feature flag payloads."
-            )
-            return None
-
-        try:
-            return remote_config(
-                self.personal_api_key,
-                self.host,
-                key,
-                timeout=self.feature_flags_request_timeout_seconds,
-            )
-        except Exception as e:
-            self.log.exception(f"[FEATURE FLAGS] Unable to get decrypted feature flag payload: {e}")
-
     def _compute_payload_locally(self, key, match_value):
         payload = None
 
         if self.feature_flags_by_key is None:
             return payload
 
-        flag_definition = self.feature_flags_by_key.get(key)
-        if flag_definition:
-            flag_filters = flag_definition.get("filters") or {}
-            flag_payloads = flag_filters.get("payloads") or {}
-            # For boolean flags, convert True to "true"
-            # For multivariate flags, use the variant string as-is
-            lookup_value = "true" if isinstance(match_value, bool) and match_value else str(match_value)
-            payload = flag_payloads.get(lookup_value, None)
+        flag_definition = self.feature_flags_by_key.get(key) or {}
+        flag_filters = flag_definition.get("filters") or {}
+        flag_payloads = flag_filters.get("payloads") or {}
+        payload = flag_payloads.get(str(match_value).lower(), None)
         return payload
 
     def get_all_flags(

posthog/exception_utils.py

@@ -793,7 +793,7 @@ def event_from_exception(
 
 
 def _module_in_list(name, items):
-    # type: (str | None, Optional[List[str]]) -> bool
+    # type: (str, Optional[List[str]]) -> bool
     if name is None:
         return False
 

posthog/feature_flags.py

@@ -7,7 +7,6 @@ from typing import Optional
 from dateutil import parser
 from dateutil.relativedelta import relativedelta
 
-from posthog import utils
 from posthog.utils import convert_to_datetime_aware, is_valid_regex
 
 __LONG_SCALE__ = float(0xFFFFFFFFFFFFFFF)
@@ -54,9 +53,6 @@ def match_feature_flag_properties(flag, distinct_id, properties, cohort_properti
     flag_conditions = (flag.get("filters") or {}).get("groups") or []
     is_inconclusive = False
     cohort_properties = cohort_properties or {}
-    # Some filters can be explicitly set to null, which require accessing variants like so
-    flag_variants = ((flag.get("filters") or {}).get("multivariate") or {}).get("variants") or []
-    valid_variant_keys = [variant["key"] for variant in flag_variants]
 
     # Stable sort conditions with variant overrides to the top. This ensures that if overrides are present, they are
     # evaluated first, and the variant override is applied to the first matching condition.
@@ -71,7 +67,9 @@ def match_feature_flag_properties(flag, distinct_id, properties, cohort_properti
             # the matching variant
             if is_condition_match(flag, distinct_id, condition, properties, cohort_properties):
                 variant_override = condition.get("variant")
-                if variant_override and variant_override in valid_variant_keys:
+                # Some filters can be explicitly set to null, which require accessing variants like so
+                flag_variants = ((flag.get("filters") or {}).get("multivariate") or {}).get("variants") or []
+                if variant_override and variant_override in [variant["key"] for variant in flag_variants]:
                     variant = variant_override
                 else:
                     variant = get_matching_variant(flag, distinct_id)
@@ -130,8 +128,8 @@ def match_property(property, property_values) -> bool:
 
         def compute_exact_match(value, override_value):
             if isinstance(value, list):
-                return str(override_value).casefold() in [str(val).casefold() for val in value]
-            return utils.str_iequals(value, override_value)
+                return str(override_value).lower() in [str(val).lower() for val in value]
+            return str(value).lower() == str(override_value).lower()
 
         if operator == "exact":
             return compute_exact_match(value, override_value)
@@ -142,10 +140,10 @@ def match_property(property, property_values) -> bool:
         return key in property_values
 
     if operator == "icontains":
-        return utils.str_icontains(override_value, value)
+        return str(value).lower() in str(override_value).lower()
 
     if operator == "not_icontains":
-        return not utils.str_icontains(override_value, value)
+        return str(value).lower() not in str(override_value).lower()
 
     if operator == "regex":
         return is_valid_regex(str(value)) and re.compile(str(value)).search(str(override_value)) is not None

posthog/request.py

@@ -11,9 +11,7 @@ from dateutil.tz import tzutc
 from posthog.utils import remove_trailing_slash
 from posthog.version import VERSION
 
-adapter = requests.adapters.HTTPAdapter(max_retries=2)
 _session = requests.sessions.Session()
-_session.mount("https://", adapter)
 
 US_INGESTION_ENDPOINT = "https://us.i.posthog.com"
 EU_INGESTION_ENDPOINT = "https://eu.i.posthog.com"
@@ -68,21 +66,7 @@ def _process_response(
     log = logging.getLogger("posthog")
     if res.status_code == 200:
         log.debug(success_message)
-        response = res.json() if return_json else res
-        # Handle quota limited decide responses by raising a specific error
-        # NB: other services also put entries into the quotaLimited key, but right now we only care about feature flags
-        # since most of the other services handle quota limiting in other places in the application.
-        if (
-            isinstance(response, dict)
-            and "quotaLimited" in response
-            and isinstance(response["quotaLimited"], list)
-            and "feature_flags" in response["quotaLimited"]
-        ):
-            log.warning(
-                "[FEATURE FLAGS] PostHog feature flags quota limited, resetting feature flag data.  Learn more about billing limits at https://posthog.com/docs/billing/limits-alerts"
-            )
-            raise QuotaLimitError(res.status_code, "Feature flags quota limited")
-        return response
+        return res.json() if return_json else res
     try:
         payload = res.json()
         log.debug("received response: %s", payload)
@@ -97,11 +81,6 @@ def decide(api_key: str, host: Optional[str] = None, gzip: bool = False, timeout
     return _process_response(res, success_message="Feature flags decided successfully")
 
 
-def remote_config(personal_api_key: str, host: Optional[str] = None, key: str = "", timeout: int = 15) -> Any:
-    """Get remote config flag value from remote_config API endpoint"""
-    return get(personal_api_key, f"/api/projects/@current/feature_flags/{key}/remote_config/", host, timeout)
-
-
 def batch_post(
     api_key: str, host: Optional[str] = None, gzip: bool = False, timeout: int = 15, **kwargs
 ) -> requests.Response:
@@ -126,10 +105,6 @@ class APIError(Exception):
         return msg.format(self.message, self.status)
 
 
-class QuotaLimitError(APIError):
-    pass
-
-
 class DatetimeSerializer(json.JSONEncoder):
     def default(self, obj: Any):
         if isinstance(obj, (date, datetime)):

posthog/test/ai/anthropic/test_anthropic.py

@@ -55,28 +55,6 @@ def mock_anthropic_stream():
     return stream_generator()
 
 
-@pytest.fixture
-def mock_anthropic_response_with_cached_tokens():
-    # Create a mock Usage object with cached_tokens in input_tokens_details
-    usage = Usage(
-        input_tokens=20,
-        output_tokens=10,
-        cache_read_input_tokens=15,
-        cache_creation_input_tokens=2,
-    )
-
-    return Message(
-        id="msg_123",
-        type="message",
-        role="assistant",
-        content=[{"type": "text", "text": "Test response"}],
-        model="claude-3-opus-20240229",
-        usage=usage,
-        stop_reason="end_turn",
-        stop_sequence=None,
-    )
-
-
 def test_basic_completion(mock_client, mock_anthropic_response):
     with patch("anthropic.resources.Messages.create", return_value=mock_anthropic_response):
         client = Anthropic(api_key="test-key", posthog_client=mock_client)
@@ -361,34 +339,3 @@ def test_error(mock_client, mock_anthropic_response):
         props = call_args["properties"]
         assert props["$ai_is_error"] is True
         assert props["$ai_error"] == "Test error"
-
-
-def test_cached_tokens(mock_client, mock_anthropic_response_with_cached_tokens):
-    with patch("anthropic.resources.Messages.create", return_value=mock_anthropic_response_with_cached_tokens):
-        client = Anthropic(api_key="test-key", posthog_client=mock_client)
-        response = client.messages.create(
-            model="claude-3-opus-20240229",
-            messages=[{"role": "user", "content": "Hello"}],
-            posthog_distinct_id="test-id",
-            posthog_properties={"foo": "bar"},
-        )
-
-        assert response == mock_anthropic_response_with_cached_tokens
-        assert mock_client.capture.call_count == 1
-
-        call_args = mock_client.capture.call_args[1]
-        props = call_args["properties"]
-
-        assert call_args["distinct_id"] == "test-id"
-        assert call_args["event"] == "$ai_generation"
-        assert props["$ai_provider"] == "anthropic"
-        assert props["$ai_model"] == "claude-3-opus-20240229"
-        assert props["$ai_input"] == [{"role": "user", "content": "Hello"}]
-        assert props["$ai_output_choices"] == [{"role": "assistant", "content": "Test response"}]
-        assert props["$ai_input_tokens"] == 20
-        assert props["$ai_output_tokens"] == 10
-        assert props["$ai_cache_read_input_tokens"] == 15
-        assert props["$ai_cache_creation_input_tokens"] == 2
-        assert props["$ai_http_status"] == 200
-        assert props["foo"] == "bar"
-        assert isinstance(props["$ai_latency"], float)

posthog/test/ai/langchain/test_callbacks.py

@@ -1168,61 +1168,6 @@ async def test_async_anthropic_streaming(mock_client):
     assert isinstance(trace_props["$ai_output_state"], AIMessage)
 
 
-def test_metadata_tools(mock_client):
-    callbacks = CallbackHandler(mock_client)
-    run_id = uuid.uuid4()
-    tools = [
-        [
-            {
-                "type": "function",
-                "function": {
-                    "name": "foo",
-                    "description": "The foo.",
-                    "parameters": {
-                        "properties": {
-                            "bar": {
-                                "description": "The bar of foo.",
-                                "type": "string",
-                            },
-                        },
-                        "required": ["query_description", "query_kind"],
-                        "type": "object",
-                        "additionalProperties": False,
-                    },
-                    "strict": True,
-                },
-            }
-        ]
-    ]
-
-    with patch("time.time", return_value=1234567890):
-        callbacks._set_llm_metadata(
-            {"kwargs": {"openai_api_base": "https://us.posthog.com"}},
-            run_id,
-            messages=[{"role": "user", "content": "What's the weather like in SF?"}],
-            invocation_params={"temperature": 0.5, "tools": tools},
-            metadata={"ls_model_name": "hog-mini", "ls_provider": "posthog"},
-            name="test",
-        )
-    expected = GenerationMetadata(
-        model="hog-mini",
-        input=[{"role": "user", "content": "What's the weather like in SF?"}],
-        start_time=1234567890,
-        model_params={"temperature": 0.5},
-        provider="posthog",
-        base_url="https://us.posthog.com",
-        name="test",
-        tools=tools,
-        end_time=None,
-    )
-    assert callbacks._runs[run_id] == expected
-    with patch("time.time", return_value=1234567891):
-        run = callbacks._pop_run_metadata(run_id)
-    expected.end_time = 1234567891
-    assert run == expected
-    assert callbacks._runs == {}
-
-
 def test_tool_calls(mock_client):
     prompt = ChatPromptTemplate.from_messages([("user", "Foo")])
     model = FakeMessagesListChatModel(

posthog/test/ai/openai/test_openai.py

@@ -1,14 +1,9 @@
-import json
 import time
 from unittest.mock import patch
 
 import pytest
 from openai.types.chat import ChatCompletion, ChatCompletionMessage
 from openai.types.chat.chat_completion import Choice
-from openai.types.chat.chat_completion_chunk import ChatCompletionChunk
-from openai.types.chat.chat_completion_chunk import Choice as ChoiceChunk
-from openai.types.chat.chat_completion_chunk import ChoiceDelta, ChoiceDeltaToolCall, ChoiceDeltaToolCallFunction
-from openai.types.chat.chat_completion_message_tool_call import ChatCompletionMessageToolCall, Function
 from openai.types.completion_usage import CompletionUsage
 from openai.types.create_embedding_response import CreateEmbeddingResponse, Usage
 from openai.types.embedding import Embedding
@@ -67,67 +62,6 @@ def mock_embedding_response():
     )
 
 
-@pytest.fixture
-def mock_openai_response_with_cached_tokens():
-    return ChatCompletion(
-        id="test",
-        model="gpt-4",
-        object="chat.completion",
-        created=int(time.time()),
-        choices=[
-            Choice(
-                finish_reason="stop",
-                index=0,
-                message=ChatCompletionMessage(
-                    content="Test response",
-                    role="assistant",
-                ),
-            )
-        ],
-        usage=CompletionUsage(
-            completion_tokens=10,
-            prompt_tokens=20,
-            total_tokens=30,
-            prompt_tokens_details={"cached_tokens": 15},
-        ),
-    )
-
-
-@pytest.fixture
-def mock_openai_response_with_tool_calls():
-    return ChatCompletion(
-        id="test",
-        model="gpt-4",
-        object="chat.completion",
-        created=int(time.time()),
-        choices=[
-            Choice(
-                finish_reason="tool_calls",
-                index=0,
-                message=ChatCompletionMessage(
-                    content="I'll check the weather for you.",
-                    role="assistant",
-                    tool_calls=[
-                        ChatCompletionMessageToolCall(
-                            id="call_abc123",
-                            type="function",
-                            function=Function(
-                                name="get_weather",
-                                arguments='{"location": "San Francisco", "unit": "celsius"}',
-                            ),
-                        )
-                    ],
-                ),
-            )
-        ],
-        usage=CompletionUsage(
-            completion_tokens=15,
-            prompt_tokens=20,
-            total_tokens=35,
-        ),
-    )
-
-
 def test_basic_completion(mock_client, mock_openai_response):
     with patch("openai.resources.chat.completions.Completions.create", return_value=mock_openai_response):
         client = OpenAI(api_key="test-key", posthog_client=mock_client)
@@ -253,249 +187,3 @@ def test_error(mock_client, mock_openai_response):
         props = call_args["properties"]
         assert props["$ai_is_error"] is True
         assert props["$ai_error"] == "Test error"
-
-
-def test_cached_tokens(mock_client, mock_openai_response_with_cached_tokens):
-    with patch(
-        "openai.resources.chat.completions.Completions.create", return_value=mock_openai_response_with_cached_tokens
-    ):
-        client = OpenAI(api_key="test-key", posthog_client=mock_client)
-        response = client.chat.completions.create(
-            model="gpt-4",
-            messages=[{"role": "user", "content": "Hello"}],
-            posthog_distinct_id="test-id",
-            posthog_properties={"foo": "bar"},
-        )
-
-        assert response == mock_openai_response_with_cached_tokens
-        assert mock_client.capture.call_count == 1
-
-        call_args = mock_client.capture.call_args[1]
-        props = call_args["properties"]
-
-        assert call_args["distinct_id"] == "test-id"
-        assert call_args["event"] == "$ai_generation"
-        assert props["$ai_provider"] == "openai"
-        assert props["$ai_model"] == "gpt-4"
-        assert props["$ai_input"] == [{"role": "user", "content": "Hello"}]
-        assert props["$ai_output_choices"] == [{"role": "assistant", "content": "Test response"}]
-        assert props["$ai_input_tokens"] == 20
-        assert props["$ai_output_tokens"] == 10
-        assert props["$ai_cache_read_input_tokens"] == 15
-        assert props["$ai_http_status"] == 200
-        assert props["foo"] == "bar"
-        assert isinstance(props["$ai_latency"], float)
-
-
-def test_tool_calls(mock_client, mock_openai_response_with_tool_calls):
-    with patch(
-        "openai.resources.chat.completions.Completions.create", return_value=mock_openai_response_with_tool_calls
-    ):
-        client = OpenAI(api_key="test-key", posthog_client=mock_client)
-        response = client.chat.completions.create(
-            model="gpt-4",
-            messages=[{"role": "user", "content": "What's the weather in San Francisco?"}],
-            tools=[
-                {
-                    "type": "function",
-                    "function": {"name": "get_weather", "description": "Get weather", "parameters": {}},
-                }
-            ],
-            posthog_distinct_id="test-id",
-        )
-
-        assert response == mock_openai_response_with_tool_calls
-        assert mock_client.capture.call_count == 1
-
-        call_args = mock_client.capture.call_args[1]
-        props = call_args["properties"]
-
-        assert call_args["distinct_id"] == "test-id"
-        assert call_args["event"] == "$ai_generation"
-        assert props["$ai_provider"] == "openai"
-        assert props["$ai_model"] == "gpt-4"
-        assert props["$ai_input"] == [{"role": "user", "content": "What's the weather in San Francisco?"}]
-        assert props["$ai_output_choices"] == [{"role": "assistant", "content": "I'll check the weather for you."}]
-
-        # Check that tool calls are properly captured
-        assert "$ai_tools" in props
-        tool_calls = props["$ai_tools"]
-        assert len(tool_calls) == 1
-
-        # Verify the tool call details
-        tool_call = tool_calls[0]
-        assert tool_call.id == "call_abc123"
-        assert tool_call.type == "function"
-        assert tool_call.function.name == "get_weather"
-
-        # Verify the arguments
-        arguments = tool_call.function.arguments
-        parsed_args = json.loads(arguments)
-        assert parsed_args == {"location": "San Francisco", "unit": "celsius"}
-
-        # Check token usage
-        assert props["$ai_input_tokens"] == 20
-        assert props["$ai_output_tokens"] == 15
-        assert props["$ai_http_status"] == 200
-
-
-def test_streaming_with_tool_calls(mock_client):
-    # Create mock tool call chunks that will be returned in sequence
-    tool_call_chunks = [
-        ChatCompletionChunk(
-            id="chunk1",
-            model="gpt-4",
-            object="chat.completion.chunk",
-            created=1234567890,
-            choices=[
-                ChoiceChunk(
-                    index=0,
-                    delta=ChoiceDelta(
-                        role="assistant",
-                        tool_calls=[
-                            ChoiceDeltaToolCall(
-                                index=0,
-                                id="call_abc123",
-                                type="function",
-                                function=ChoiceDeltaToolCallFunction(
-                                    name="get_weather",
-                                    arguments='{"location": "',
-                                ),
-                            )
-                        ],
-                    ),
-                    finish_reason=None,
-                )
-            ],
-        ),
-        ChatCompletionChunk(
-            id="chunk2",
-            model="gpt-4",
-            object="chat.completion.chunk",
-            created=1234567891,
-            choices=[
-                ChoiceChunk(
-                    index=0,
-                    delta=ChoiceDelta(
-                        tool_calls=[
-                            ChoiceDeltaToolCall(
-                                index=0,
-                                id="call_abc123",
-                                type="function",
-                                function=ChoiceDeltaToolCallFunction(
-                                    arguments='San Francisco"',
-                                ),
-                            )
-                        ],
-                    ),
-                    finish_reason=None,
-                )
-            ],
-        ),
-        ChatCompletionChunk(
-            id="chunk3",
-            model="gpt-4",
-            object="chat.completion.chunk",
-            created=1234567892,
-            choices=[
-                ChoiceChunk(
-                    index=0,
-                    delta=ChoiceDelta(
-                        tool_calls=[
-                            ChoiceDeltaToolCall(
-                                index=0,
-                                id="call_abc123",
-                                type="function",
-                                function=ChoiceDeltaToolCallFunction(
-                                    arguments=', "unit": "celsius"}',
-                                ),
-                            )
-                        ],
-                    ),
-                    finish_reason=None,
-                )
-            ],
-        ),
-        ChatCompletionChunk(
-            id="chunk4",
-            model="gpt-4",
-            object="chat.completion.chunk",
-            created=1234567893,
-            choices=[
-                ChoiceChunk(
-                    index=0,
-                    delta=ChoiceDelta(
-                        content="The weather in San Francisco is 15°C.",
-                    ),
-                    finish_reason=None,
-                )
-            ],
-            usage=CompletionUsage(
-                prompt_tokens=20,
-                completion_tokens=15,
-                total_tokens=35,
-            ),
-        ),
-    ]
-
-    # Mock the create method to return our chunks
-    with patch("openai.resources.chat.completions.Completions.create") as mock_create:
-        # Set up the mock to return our chunks when iterated
-        mock_create.return_value = tool_call_chunks
-
-        client = OpenAI(api_key="test-key", posthog_client=mock_client)
-
-        # Call the streaming method
-        response_generator = client.chat.completions.create(
-            model="gpt-4",
-            messages=[{"role": "user", "content": "What's the weather in San Francisco?"}],
-            tools=[
-                {
-                    "type": "function",
-                    "function": {"name": "get_weather", "description": "Get weather", "parameters": {}},
-                }
-            ],
-            stream=True,
-            posthog_distinct_id="test-id",
-        )
-
-        # Consume the generator to trigger the event capture
-        chunks = list(response_generator)
-
-        # Verify the chunks were returned correctly
-        assert len(chunks) == 4
-        assert chunks == tool_call_chunks
-
-        # Verify the capture was called with the right arguments
-        assert mock_client.capture.call_count == 1
-
-        call_args = mock_client.capture.call_args[1]
-        props = call_args["properties"]
-
-        assert call_args["distinct_id"] == "test-id"
-        assert call_args["event"] == "$ai_generation"
-        assert props["$ai_provider"] == "openai"
-        assert props["$ai_model"] == "gpt-4"
-
-        # Check that the tool calls were properly accumulated
-        assert "$ai_tools" in props
-        tool_calls = props["$ai_tools"]
-        assert len(tool_calls) == 1
-
-        # Verify the complete tool call was properly assembled
-        tool_call = tool_calls[0]
-        assert tool_call.id == "call_abc123"
-        assert tool_call.type == "function"
-        assert tool_call.function.name == "get_weather"
-
-        # Verify the arguments were concatenated correctly
-        arguments = tool_call.function.arguments
-        parsed_args = json.loads(arguments)
-        assert parsed_args == {"location": "San Francisco", "unit": "celsius"}
-
-        # Check that the content was also accumulated
-        assert props["$ai_output_choices"][0]["content"] == "The weather in San Francisco is 15°C."
-
-        # Check token usage
-        assert props["$ai_input_tokens"] == 20
-        assert props["$ai_output_tokens"] == 15

posthog/test/test_client.py

@@ -5,10 +5,8 @@ from uuid import uuid4
 
 import mock
 import six
-from parameterized import parameterized
 
 from posthog.client import Client
-from posthog.request import APIError
 from posthog.test.test_utils import FAKE_TEST_API_KEY
 from posthog.version import VERSION
 
@@ -55,11 +53,6 @@ class TestClient(unittest.TestCase):
         self.assertEqual(msg["distinct_id"], "distinct_id")
         self.assertEqual(msg["properties"]["$lib"], "posthog-python")
         self.assertEqual(msg["properties"]["$lib_version"], VERSION)
-        # these will change between platforms so just asssert on presence here
-        assert msg["properties"]["$python_runtime"] == mock.ANY
-        assert msg["properties"]["$python_version"] == mock.ANY
-        assert msg["properties"]["$os"] == mock.ANY
-        assert msg["properties"]["$os_version"] == mock.ANY
 
     def test_basic_capture_with_uuid(self):
         client = self.client
@@ -107,6 +100,7 @@ class TestClient(unittest.TestCase):
         self.assertEqual(msg["properties"]["source"], "repo-name")
 
     def test_basic_capture_exception(self):
+
         with mock.patch.object(Client, "capture", return_value=None) as patch_capture:
             client = self.client
             exception = Exception("test exception")
@@ -134,6 +128,7 @@ class TestClient(unittest.TestCase):
             )
 
     def test_basic_capture_exception_with_distinct_id(self):
+
         with mock.patch.object(Client, "capture", return_value=None) as patch_capture:
             client = self.client
             exception = Exception("test exception")
@@ -161,6 +156,7 @@ class TestClient(unittest.TestCase):
             )
 
     def test_basic_capture_exception_with_correct_host_generation(self):
+
         with mock.patch.object(Client, "capture", return_value=None) as patch_capture:
             client = Client(FAKE_TEST_API_KEY, on_error=self.set_fail, host="https://aloha.com")
             exception = Exception("test exception")
@@ -188,6 +184,7 @@ class TestClient(unittest.TestCase):
             )
 
     def test_basic_capture_exception_with_correct_host_generation_for_server_hosts(self):
+
         with mock.patch.object(Client, "capture", return_value=None) as patch_capture:
             client = Client(FAKE_TEST_API_KEY, on_error=self.set_fail, host="https://app.posthog.com")
             exception = Exception("test exception")
@@ -215,6 +212,7 @@ class TestClient(unittest.TestCase):
             )
 
     def test_basic_capture_exception_with_no_exception_given(self):
+
         with mock.patch.object(Client, "capture", return_value=None) as patch_capture:
             client = self.client
             try:
@@ -251,8 +249,10 @@ class TestClient(unittest.TestCase):
             self.assertEqual(capture_call[2]["$exception_list"][0]["stacktrace"]["frames"][0]["in_app"], True)
 
     def test_basic_capture_exception_with_no_exception_happening(self):
+
         with mock.patch.object(Client, "capture", return_value=None) as patch_capture:
             with self.assertLogs("posthog", level="WARNING") as logs:
+
                 client = self.client
                 client.capture_exception()
 
@@ -292,6 +292,7 @@ class TestClient(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "beta-feature-local",
+            "is_simple_flag": False,
             "active": True,
             "rollout_percentage": 100,
             "filters": {
@@ -320,6 +321,7 @@ class TestClient(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "person-flag",
+            "is_simple_flag": True,
             "active": True,
             "filters": {
                 "groups": [
@@ -342,6 +344,7 @@ class TestClient(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "false-flag",
+            "is_simple_flag": True,
             "active": True,
             "filters": {
                 "groups": [
@@ -384,25 +387,6 @@ class TestClient(unittest.TestCase):
         assert "$feature/false-flag" not in msg["properties"]
         assert "$active_feature_flags" not in msg["properties"]
 
-    @mock.patch("posthog.client.get")
-    def test_load_feature_flags_quota_limited(self, patch_get):
-        mock_response = {
-            "type": "quota_limited",
-            "detail": "You have exceeded your feature flag request quota",
-            "code": "payment_required",
-        }
-        patch_get.side_effect = APIError(402, mock_response["detail"])
-
-        client = Client(FAKE_TEST_API_KEY, personal_api_key="test")
-        with self.assertLogs("posthog", level="WARNING") as logs:
-            client._load_feature_flags()
-
-            self.assertEqual(client.feature_flags, [])
-            self.assertEqual(client.feature_flags_by_key, {})
-            self.assertEqual(client.group_type_mapping, {})
-            self.assertEqual(client.cohorts, {})
-            self.assertIn("PostHog feature flags quota limited", logs.output[0])
-
     @mock.patch("posthog.client.decide")
     def test_dont_override_capture_with_local_flags(self, patch_decide):
         patch_decide.return_value = {"featureFlags": {"beta-feature": "random-variant"}}
@@ -412,6 +396,7 @@ class TestClient(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "beta-feature-local",
+            "is_simple_flag": False,
             "active": True,
             "rollout_percentage": 100,
             "filters": {
@@ -440,6 +425,7 @@ class TestClient(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "person-flag",
+            "is_simple_flag": True,
             "active": True,
             "filters": {
                 "groups": [
@@ -595,8 +581,8 @@ class TestClient(unittest.TestCase):
             "distinct_id",
             "python test event",
             {"property": "value"},
-            timestamp=datetime(2014, 9, 3),
-            uuid="new-uuid",
+            datetime(2014, 9, 3),
+            "new-uuid",
         )
 
         self.assertTrue(success)
@@ -634,9 +620,7 @@ class TestClient(unittest.TestCase):
 
     def test_advanced_identify(self):
         client = self.client
-        success, msg = client.identify(
-            "distinct_id", {"trait": "value"}, timestamp=datetime(2014, 9, 3), uuid="new-uuid"
-        )
+        success, msg = client.identify("distinct_id", {"trait": "value"}, datetime(2014, 9, 3), "new-uuid")
 
         self.assertTrue(success)
 
@@ -662,7 +646,7 @@ class TestClient(unittest.TestCase):
 
     def test_advanced_set(self):
         client = self.client
-        success, msg = client.set("distinct_id", {"trait": "value"}, timestamp=datetime(2014, 9, 3), uuid="new-uuid")
+        success, msg = client.set("distinct_id", {"trait": "value"}, datetime(2014, 9, 3), "new-uuid")
 
         self.assertTrue(success)
 
@@ -688,9 +672,7 @@ class TestClient(unittest.TestCase):
 
     def test_advanced_set_once(self):
         client = self.client
-        success, msg = client.set_once(
-            "distinct_id", {"trait": "value"}, timestamp=datetime(2014, 9, 3), uuid="new-uuid"
-        )
+        success, msg = client.set_once("distinct_id", {"trait": "value"}, datetime(2014, 9, 3), "new-uuid")
 
         self.assertTrue(success)
 
@@ -743,7 +725,7 @@ class TestClient(unittest.TestCase):
 
     def test_advanced_group_identify(self):
         success, msg = self.client.group_identify(
-            "organization", "id:5", {"trait": "value"}, timestamp=datetime(2014, 9, 3), uuid="new-uuid"
+            "organization", "id:5", {"trait": "value"}, datetime(2014, 9, 3), "new-uuid"
         )
 
         self.assertTrue(success)
@@ -767,8 +749,8 @@ class TestClient(unittest.TestCase):
             "organization",
             "id:5",
             {"trait": "value"},
-            timestamp=datetime(2014, 9, 3),
-            uuid="new-uuid",
+            datetime(2014, 9, 3),
+            "new-uuid",
             distinct_id="distinct_id",
         )
 
@@ -823,8 +805,8 @@ class TestClient(unittest.TestCase):
             "distinct_id",
             "https://posthog.com/contact",
             {"property": "value"},
-            timestamp=datetime(2014, 9, 3),
-            uuid="new-uuid",
+            datetime(2014, 9, 3),
+            "new-uuid",
         )
 
         self.assertTrue(success)
@@ -1053,7 +1035,7 @@ class TestClient(unittest.TestCase):
 
         patch_get.return_value.raiseError.side_effect = raise_effect
         client = Client(FAKE_TEST_API_KEY, personal_api_key="test")
-        client.feature_flags = [{"key": "example"}]
+        client.feature_flags = [{"key": "example", "is_simple_flag": False}]
 
         self.assertFalse(client.feature_enabled("example", "distinct_id"))
 
@@ -1123,92 +1105,3 @@ class TestClient(unittest.TestCase):
             group_properties={},
             disable_geoip=False,
         )
-
-    @parameterized.expand(
-        [
-            # name, sys_platform, version_info, expected_runtime, expected_version, expected_os, expected_os_version, platform_method, platform_return, distro_info
-            (
-                "macOS",
-                "darwin",
-                (3, 8, 10),
-                "MockPython",
-                "3.8.10",
-                "Mac OS X",
-                "10.15.7",
-                "mac_ver",
-                ("10.15.7", "", ""),
-                None,
-            ),
-            (
-                "Windows",
-                "win32",
-                (3, 8, 10),
-                "MockPython",
-                "3.8.10",
-                "Windows",
-                "10",
-                "win32_ver",
-                ("10", "", "", ""),
-                None,
-            ),
-            (
-                "Linux",
-                "linux",
-                (3, 8, 10),
-                "MockPython",
-                "3.8.10",
-                "Linux",
-                "20.04",
-                None,
-                None,
-                {"version": "20.04"},
-            ),
-        ]
-    )
-    def test_mock_system_context(
-        self,
-        _name,
-        sys_platform,
-        version_info,
-        expected_runtime,
-        expected_version,
-        expected_os,
-        expected_os_version,
-        platform_method,
-        platform_return,
-        distro_info,
-    ):
-        """Test that we can mock platform and sys for testing system_context"""
-        with mock.patch("posthog.client.platform") as mock_platform:
-            with mock.patch("posthog.client.sys") as mock_sys:
-                # Set up common mocks
-                mock_platform.python_implementation.return_value = expected_runtime
-                mock_sys.version_info = version_info
-                mock_sys.platform = sys_platform
-
-                # Set up platform-specific mocks
-                if platform_method:
-                    getattr(mock_platform, platform_method).return_value = platform_return
-
-                # Special handling for Linux which uses distro module
-                if sys_platform == "linux":
-                    # Directly patch the get_os_info function to return our expected values
-                    with mock.patch("posthog.client.get_os_info", return_value=(expected_os, expected_os_version)):
-                        from posthog.client import system_context
-
-                        context = system_context()
-                else:
-                    # Get system context for non-Linux platforms
-                    from posthog.client import system_context
-
-                    context = system_context()
-
-                # Verify results
-                expected_context = {
-                    "$python_runtime": expected_runtime,
-                    "$python_version": expected_version,
-                    "$os": expected_os,
-                    "$os_version": expected_os_version,
-                }
-
-                assert context == expected_context

posthog/test/test_feature_flags.py

@@ -38,6 +38,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "person-flag",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -68,59 +69,6 @@ class TestLocalEvaluation(unittest.TestCase):
         self.assertTrue(feature_flag_match)
         self.assertFalse(not_feature_flag_match)
 
-    def test_case_insensitive_matching(self):
-        self.client.feature_flags = [
-            {
-                "id": 1,
-                "name": "Beta Feature",
-                "key": "person-flag",
-                "is_simple_flag": True,
-                "active": True,
-                "filters": {
-                    "groups": [
-                        {
-                            "properties": [
-                                {
-                                    "key": "location",
-                                    "operator": "exact",
-                                    "value": ["Straße"],
-                                    "type": "person",
-                                }
-                            ],
-                            "rollout_percentage": 100,
-                        },
-                        {
-                            "properties": [
-                                {
-                                    "key": "star",
-                                    "operator": "exact",
-                                    "value": ["ſun"],
-                                    "type": "person",
-                                }
-                            ],
-                            "rollout_percentage": 100,
-                        },
-                    ],
-                },
-            }
-        ]
-
-        self.assertTrue(
-            self.client.get_feature_flag("person-flag", "some-distinct-id", person_properties={"location": "straße"})
-        )
-
-        self.assertTrue(
-            self.client.get_feature_flag("person-flag", "some-distinct-id", person_properties={"location": "strasse"})
-        )
-
-        self.assertTrue(
-            self.client.get_feature_flag("person-flag", "some-distinct-id", person_properties={"star": "ſun"})
-        )
-
-        self.assertTrue(
-            self.client.get_feature_flag("person-flag", "some-distinct-id", person_properties={"star": "sun"})
-        )
-
     @mock.patch("posthog.client.decide")
     @mock.patch("posthog.client.get")
     def test_flag_group_properties(self, patch_get, patch_decide):
@@ -129,6 +77,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "group-flag",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "aggregation_group_type_index": 0,
@@ -221,6 +170,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "complex-flag",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -336,6 +286,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -350,6 +301,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "beta-feature2",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -391,6 +343,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -405,6 +358,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "beta-feature2",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -456,6 +410,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -502,6 +457,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -516,7 +472,7 @@ class TestLocalEvaluation(unittest.TestCase):
             }
         ]
         # decide called always because experience_continuity is set
-        self.assertEqual(client.get_feature_flag("beta-feature", "distinct_id"), "decide-fallback-value")
+        self.assertTrue(client.get_feature_flag("beta-feature", "distinct_id"), "decide-fallback-value")
         self.assertEqual(patch_decide.call_count, 1)
 
     @mock.patch.object(Client, "capture")
@@ -531,6 +487,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -546,6 +503,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "disabled-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -560,6 +518,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 3,
                 "name": "Beta Feature",
                 "key": "beta-feature2",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -592,6 +551,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -610,6 +570,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "disabled-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -627,6 +588,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 3,
                 "name": "Beta Feature",
                 "key": "beta-feature2",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -692,6 +654,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -707,6 +670,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "disabled-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -732,6 +696,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "beta-feature",
+            "is_simple_flag": False,
             "active": True,
             "rollout_percentage": 100,
             "filters": {
@@ -750,6 +715,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 2,
             "name": "Beta Feature",
             "key": "disabled-feature",
+            "is_simple_flag": False,
             "active": True,
             "filters": {
                 "groups": [
@@ -785,6 +751,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -800,6 +767,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "disabled-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -814,6 +782,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 3,
                 "name": "Beta Feature",
                 "key": "beta-feature2",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -845,6 +814,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "beta-feature",
+            "is_simple_flag": False,
             "active": True,
             "rollout_percentage": 100,
             "filters": {
@@ -863,6 +833,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 2,
             "name": "Beta Feature",
             "key": "disabled-feature",
+            "is_simple_flag": False,
             "active": True,
             "filters": {
                 "groups": [
@@ -880,6 +851,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 3,
             "name": "Beta Feature",
             "key": "beta-feature2",
+            "is_simple_flag": False,
             "active": True,
             "filters": {
                 "groups": [
@@ -916,6 +888,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -931,6 +904,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "disabled-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -953,6 +927,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": False,
                 "rollout_percentage": 100,
                 "filters": {
@@ -968,6 +943,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "disabled-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -993,6 +969,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 id: 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -1030,15 +1007,13 @@ class TestLocalEvaluation(unittest.TestCase):
             "beta-feature",
             "some-distinct-id",
             person_properties={
-                "latestBuildVersion": "24.32.1",
+                "latestBuildVersion": "24.32..1",
                 "latestBuildVersionMajor": "24",
                 "latestBuildVersionMinor": "32",
                 "latestBuildVersionPatch": "1",
             },
         )
 
-        self.assertEqual(feature_flag_match, True)
-
     @mock.patch("posthog.client.decide")
     @mock.patch("posthog.client.get")
     def test_feature_flags_local_evaluation_for_cohorts(self, patch_get, patch_decide):
@@ -1048,6 +1023,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -1118,6 +1094,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 2,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -1230,6 +1207,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1254,6 +1232,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "rollout_percentage": 0,
                 "filters": {
@@ -1278,6 +1257,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "rollout_percentage": None,
                 "filters": {
@@ -1301,6 +1281,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1324,6 +1305,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1348,6 +1330,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -1369,6 +1352,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1434,6 +1418,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1474,6 +1459,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1525,6 +1511,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1565,6 +1552,7 @@ class TestLocalEvaluation(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "beta-feature",
+                "is_simple_flag": False,
                 "active": True,
                 "rollout_percentage": 100,
                 "filters": {
@@ -1607,6 +1595,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "person-flag",
+            "is_simple_flag": True,
             "active": True,
             "filters": {
                 "groups": [
@@ -1670,6 +1659,7 @@ class TestLocalEvaluation(unittest.TestCase):
             "id": 1,
             "name": "Beta Feature",
             "key": "beta-feature",
+            "is_simple_flag": False,
             "active": True,
             "rollout_percentage": 100,
             "filters": {
@@ -2247,6 +2237,7 @@ class TestCaptureCalls(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "complex-flag",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -2346,55 +2337,6 @@ class TestCaptureCalls(unittest.TestCase):
             disable_geoip=None,
         )
 
-    @mock.patch("posthog.client.decide")
-    def test_capture_is_called_but_does_not_add_all_flags(self, patch_decide):
-        patch_decide.return_value = {"featureFlags": {"decide-flag": "decide-value"}}
-        client = Client(FAKE_TEST_API_KEY, personal_api_key=FAKE_TEST_API_KEY)
-        client.feature_flags = [
-            {
-                "id": 1,
-                "name": "Beta Feature",
-                "key": "complex-flag",
-                "active": True,
-                "filters": {
-                    "groups": [
-                        {
-                            "properties": [{"key": "region", "value": "USA"}],
-                            "rollout_percentage": 100,
-                        },
-                    ],
-                },
-            },
-            {
-                "id": 2,
-                "name": "Gamma Feature",
-                "key": "simple-flag",
-                "active": True,
-                "filters": {
-                    "groups": [
-                        {
-                            "properties": [],
-                            "rollout_percentage": 100,
-                        },
-                    ],
-                },
-            },
-        ]
-
-        self.assertTrue(
-            client.get_feature_flag("complex-flag", "some-distinct-id", person_properties={"region": "USA"})
-        )
-
-        # Grab the capture message that was just added to the queue
-        msg = client.queue.get(block=False)
-        assert msg["event"] == "$feature_flag_called"
-        assert msg["properties"]["$feature_flag"] == "complex-flag"
-        assert msg["properties"]["$feature_flag_response"] is True
-        assert msg["properties"]["locally_evaluated"] is True
-        assert msg["properties"]["$feature/complex-flag"] is True
-        assert "$feature/simple-flag" not in msg["properties"]
-        assert "$active_feature_flags" not in msg["properties"]
-
     @mock.patch.object(Client, "capture")
     @mock.patch("posthog.client.decide")
     def test_capture_is_called_in_get_feature_flag_payload(self, patch_decide, patch_capture):
@@ -2409,6 +2351,7 @@ class TestCaptureCalls(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "person-flag",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -2486,6 +2429,7 @@ class TestCaptureCalls(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "complex-flag",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -2528,6 +2472,7 @@ class TestCaptureCalls(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "complex-flag",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [
@@ -2586,6 +2531,7 @@ class TestConsistency(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "simple-flag",
+                "is_simple_flag": True,
                 "active": True,
                 "filters": {
                     "groups": [{"properties": [], "rollout_percentage": 45}],
@@ -3613,6 +3559,7 @@ class TestConsistency(unittest.TestCase):
                 "id": 1,
                 "name": "Beta Feature",
                 "key": "multivariate-flag",
+                "is_simple_flag": False,
                 "active": True,
                 "filters": {
                     "groups": [{"properties": [], "rollout_percentage": 55}],
@@ -4640,84 +4587,3 @@ class TestConsistency(unittest.TestCase):
                 self.assertEqual(feature_flag_match, results[i])
             else:
                 self.assertFalse(feature_flag_match)
-
-    @mock.patch("posthog.client.decide")
-    def test_feature_flag_case_sensitive(self, mock_decide):
-        mock_decide.return_value = {"featureFlags": {}}  # Ensure decide returns empty flags
-
-        client = Client(api_key=FAKE_TEST_API_KEY, personal_api_key=FAKE_TEST_API_KEY)
-        client.feature_flags = [
-            {
-                "id": 1,
-                "key": "Beta-Feature",
-                "active": True,
-                "filters": {
-                    "groups": [{"properties": [], "rollout_percentage": 100}],
-                },
-            }
-        ]
-
-        # Test that flag evaluation is case-sensitive
-        self.assertTrue(client.feature_enabled("Beta-Feature", "user1"))
-        self.assertFalse(client.feature_enabled("beta-feature", "user1"))
-        self.assertFalse(client.feature_enabled("BETA-FEATURE", "user1"))
-
-    @mock.patch("posthog.client.decide")
-    def test_feature_flag_payload_case_sensitive(self, mock_decide):
-        mock_decide.return_value = {
-            "featureFlags": {"Beta-Feature": True},
-            "featureFlagPayloads": {"Beta-Feature": {"some": "value"}},
-        }
-
-        client = Client(api_key=FAKE_TEST_API_KEY, personal_api_key=FAKE_TEST_API_KEY)
-        client.feature_flags = [
-            {
-                "id": 1,
-                "key": "Beta-Feature",
-                "active": True,
-                "filters": {
-                    "groups": [{"properties": [], "rollout_percentage": 100}],
-                    "payloads": {
-                        "true": {"some": "value"},
-                    },
-                },
-            }
-        ]
-
-        # Test that payload retrieval is case-sensitive
-        self.assertEqual(client.get_feature_flag_payload("Beta-Feature", "user1"), {"some": "value"})
-        self.assertIsNone(client.get_feature_flag_payload("beta-feature", "user1"))
-        self.assertIsNone(client.get_feature_flag_payload("BETA-FEATURE", "user1"))
-
-    @mock.patch("posthog.client.decide")
-    def test_feature_flag_case_sensitive_consistency(self, mock_decide):
-        mock_decide.return_value = {
-            "featureFlags": {"Beta-Feature": True},
-            "featureFlagPayloads": {"Beta-Feature": {"some": "value"}},
-        }
-
-        client = Client(api_key=FAKE_TEST_API_KEY, personal_api_key=FAKE_TEST_API_KEY)
-        client.feature_flags = [
-            {
-                "id": 1,
-                "key": "Beta-Feature",
-                "active": True,
-                "filters": {
-                    "groups": [{"properties": [], "rollout_percentage": 100}],
-                    "payloads": {
-                        "true": {"some": "value"},
-                    },
-                },
-            }
-        ]
-
-        # Test that flag evaluation and payload retrieval are consistently case-sensitive
-        # Only exact match should work
-        self.assertTrue(client.feature_enabled("Beta-Feature", "user1"))
-        self.assertEqual(client.get_feature_flag_payload("Beta-Feature", "user1"), {"some": "value"})
-
-        # Different cases should not match
-        test_cases = ["beta-feature", "BETA-FEATURE", "bEtA-FeAtUrE"]
-        for case in test_cases:
-            self.assertFalse(client.feature_enabled(case, "user1"))
-            self.assertIsNone(client.get_feature_flag_payload(case, "user1"))

posthog/test/test_request.py

@@ -2,11 +2,10 @@ import json
 import unittest
 from datetime import date, datetime
 
-import mock
 import pytest
 import requests
 
-from posthog.request import DatetimeSerializer, QuotaLimitError, batch_post, decide, determine_server_host
+from posthog.request import DatetimeSerializer, batch_post, determine_server_host
 from posthog.test.test_utils import TEST_API_KEY
 
 
@@ -45,36 +44,6 @@ class TestRequests(unittest.TestCase):
                 "key", batch=[{"distinct_id": "distinct_id", "event": "python event", "type": "track"}], timeout=0.0001
             )
 
-    def test_quota_limited_response(self):
-        mock_response = requests.Response()
-        mock_response.status_code = 200
-        mock_response._content = json.dumps(
-            {
-                "quotaLimited": ["feature_flags"],
-                "featureFlags": {},
-                "featureFlagPayloads": {},
-                "errorsWhileComputingFlags": False,
-            }
-        ).encode("utf-8")
-
-        with mock.patch("posthog.request._session.post", return_value=mock_response):
-            with self.assertRaises(QuotaLimitError) as cm:
-                decide("fake_key", "fake_host")
-
-            self.assertEqual(cm.exception.status, 200)
-            self.assertEqual(cm.exception.message, "Feature flags quota limited")
-
-    def test_normal_decide_response(self):
-        mock_response = requests.Response()
-        mock_response.status_code = 200
-        mock_response._content = json.dumps(
-            {"featureFlags": {"flag1": True}, "featureFlagPayloads": {}, "errorsWhileComputingFlags": False}
-        ).encode("utf-8")
-
-        with mock.patch("posthog.request._session.post", return_value=mock_response):
-            response = decide("fake_key", "fake_host")
-            self.assertEqual(response["featureFlags"], {"flag1": True})
-
 
 @pytest.mark.parametrize(
     "host, expected",

posthog/utils.py

@@ -125,43 +125,3 @@ def convert_to_datetime_aware(date_obj):
     if date_obj.tzinfo is None:
         date_obj = date_obj.replace(tzinfo=timezone.utc)
     return date_obj
-
-
-def str_icontains(source, search):
-    """
-    Check if a string contains another string, ignoring case.
-
-    Args:
-        source: The string to search within
-        search: The substring to search for
-
-    Returns:
-        bool: True if search is a substring of source (case-insensitive), False otherwise
-
-    Examples:
-        >>> str_icontains("Hello World", "WORLD")
-        True
-        >>> str_icontains("Hello World", "python")
-        False
-    """
-    return str(search).casefold() in str(source).casefold()
-
-
-def str_iequals(value, comparand):
-    """
-    Check if a string equals another string, ignoring case.
-
-    Args:
-        value: The string to compare
-        comparand: The string to compare with
-
-    Returns:
-        bool: True if value and comparand are equal (case-insensitive), False otherwise
-
-    Examples:
-        >>> str_iequals("Hello World", "hello world")
-        True
-        >>> str_iequals("Hello World", "hello")
-        False
-    """
-    return str(value).casefold() == str(comparand).casefold()

posthog/version.py

@@ -1,4 +1,4 @@
-VERSION = "3.19.0"
+VERSION = "3.12.0"
 
 if __name__ == "__main__":
     print(VERSION, end="")  # noqa: T201

setup.py

@@ -20,30 +20,19 @@ install_requires = [
     "monotonic>=1.5",
     "backoff>=1.10.0",
     "python-dateutil>2.1",
-    "distro>=1.5.0",  # Required for Linux OS detection in Python 3.9+
 ]
 
 extras_require = {
     "dev": [
         "black",
-        "django-stubs",
         "isort",
         "flake8",
         "flake8-print",
-        "lxml",
-        "mypy",
-        "mypy-baseline",
-        "types-mock",
-        "types-python-dateutil",
-        "types-requests",
-        "types-setuptools",
-        "types-six",
         "pre-commit",
-        "pydantic",
     ],
     "test": [
         "mock>=2.0.0",
-        "freezegun==1.5.1",
+        "freezegun==0.3.15",
         "pylint",
         "flake8",
         "coverage",
@@ -58,7 +47,6 @@ extras_require = {
         "langchain-openai>=0.2.0",
         "langchain-anthropic>=0.2.0",
         "pydantic",
-        "parameterized>=0.8.1",
     ],
     "sentry": ["sentry-sdk", "django"],
     "langchain": ["langchain>=0.2.0"],
@@ -94,10 +82,19 @@ setup(
         "License :: OSI Approved :: MIT License",
         "Operating System :: OS Independent",
         "Programming Language :: Python",
+        "Programming Language :: Python :: 2",
+        "Programming Language :: Python :: 2.6",
+        "Programming Language :: Python :: 2.7",
+        "Programming Language :: Python :: 3",
+        "Programming Language :: Python :: 3.2",
+        "Programming Language :: Python :: 3.3",
+        "Programming Language :: Python :: 3.4",
+        "Programming Language :: Python :: 3.5",
+        "Programming Language :: Python :: 3.6",
+        "Programming Language :: Python :: 3.7",
+        "Programming Language :: Python :: 3.8",
         "Programming Language :: Python :: 3.9",
         "Programming Language :: Python :: 3.10",
         "Programming Language :: Python :: 3.11",
-        "Programming Language :: Python :: 3.12",
-        "Programming Language :: Python :: 3.13",
     ],
 )

simulator.py

@@ -24,6 +24,7 @@ parser.add_argument("--type", help="The posthog message type")
 
 parser.add_argument("--distinct_id", help="the user id to send the event as")
 parser.add_argument("--anonymousId", help="the anonymous user id to send the event as")
+parser.add_argument("--context", help="additional context for the event (JSON-encoded)")
 
 parser.add_argument("--event", help="the event name to send with the event")
 parser.add_argument("--properties", help="the event properties to send (JSON-encoded)")
@@ -47,6 +48,7 @@ def capture():
         options.event,
         anonymous_id=options.anonymousId,
         properties=json_hash(options.properties),
+        context=json_hash(options.context),
     )
 
 
@@ -56,6 +58,7 @@ def page():
         name=options.name,
         anonymous_id=options.anonymousId,
         properties=json_hash(options.properties),
+        context=json_hash(options.context),
     )
 
 
@@ -64,6 +67,7 @@ def identify():
         options.distinct_id,
         anonymous_id=options.anonymousId,
         traits=json_hash(options.traits),
+        context=json_hash(options.context),
     )
 
 
@@ -71,6 +75,7 @@ def set_once():
     posthog.set_once(
         options.distinct_id,
         properties=json_hash(options.traits),
+        context=json_hash(options.context),
     )
 
 
@@ -78,6 +83,7 @@ def set():
     posthog.set(
         options.distinct_id,
         properties=json_hash(options.traits),
+        context=json_hash(options.context),
     )