refactor!: drop timestamp param from track_event / track_exposure_event

Only intended use case was back-filling events from other sources, which is
overkill for now. EventProcessor always stamps datetime.now() at buffer time.

Author: gagantrivedi

flagsmith/analytics.py

@@ -112,7 +112,6 @@ def track_event(
         value: typing.Optional[typing.Union[str, int, float]] = None,
         traits: typing.Optional[typing.Dict[str, typing.Any]] = None,
         metadata: typing.Optional[typing.Dict[str, typing.Any]] = None,
-        timestamp: typing.Optional[datetime] = None,
     ) -> None:
         self._buffer_event(
             event=event,
@@ -121,7 +120,6 @@ def track_event(
             value=value,
             traits=traits,
             metadata=metadata,
-            timestamp=timestamp,
         )
 
     def track_exposure_event(
@@ -131,7 +129,6 @@ def track_exposure_event(
         value: typing.Optional[str] = None,
         traits: typing.Optional[typing.Dict[str, typing.Any]] = None,
         metadata: typing.Optional[typing.Dict[str, typing.Any]] = None,
-        timestamp: typing.Optional[datetime] = None,
     ) -> None:
         self._buffer_event(
             event=FLAG_EXPOSURE_EVENT,
@@ -140,7 +137,6 @@ def track_exposure_event(
             value=value,
             traits=traits,
             metadata=metadata,
-            timestamp=timestamp,
         )
 
     def _buffer_event(
@@ -151,7 +147,6 @@ def _buffer_event(
         value: typing.Optional[typing.Union[str, int, float]],
         traits: typing.Optional[typing.Dict[str, typing.Any]],
         metadata: typing.Optional[typing.Dict[str, typing.Any]],
-        timestamp: typing.Optional[datetime],
     ) -> None:
         should_flush = False
         with self._lock:
@@ -163,7 +158,7 @@ def _buffer_event(
                     "value": value,
                     "traits": dict(traits) if traits else None,
                     "metadata": {**(metadata or {}), "sdk_version": __version__},
-                    "timestamp": int((timestamp or datetime.now()).timestamp() * 1000),
+                    "timestamp": int(datetime.now().timestamp() * 1000),
                 }
             )
             if len(self._buffer) >= self._max_buffer:

flagsmith/flagsmith.py

@@ -377,7 +377,6 @@ def track_event(
         value: typing.Optional[typing.Union[str, int, float]] = None,
         traits: typing.Optional[TraitMapping] = None,
         metadata: typing.Optional[typing.Dict[str, typing.Any]] = None,
-        timestamp: typing.Optional[datetime] = None,
     ) -> None:
         if not self._event_processor:
             raise ValueError("Events must be enabled to track events.")
@@ -387,7 +386,6 @@ def track_event(
             value=value,
             traits=resolve_trait_values(traits),
             metadata=metadata,
-            timestamp=timestamp,
         )
 
     def track_exposure_event(
@@ -397,7 +395,6 @@ def track_exposure_event(
         value: typing.Optional[str] = None,
         traits: typing.Optional[TraitMapping] = None,
         metadata: typing.Optional[typing.Dict[str, typing.Any]] = None,
-        timestamp: typing.Optional[datetime] = None,
     ) -> None:
         if not self._event_processor:
             raise ValueError("Events must be enabled to track exposure events.")
@@ -407,7 +404,6 @@ def track_exposure_event(
             value=value,
             traits=resolve_trait_values(traits),
             metadata=metadata,
-            timestamp=timestamp,
         )
 
     def update_environment(self) -> None:

tests/test_event_processor.py

@@ -1,6 +1,6 @@
 import json
 from concurrent.futures import Future
-from datetime import datetime, timezone
+from datetime import datetime
 from unittest import mock
 
 from flagsmith.analytics import (
@@ -42,16 +42,6 @@ def test_track_event_defaults_timestamp_to_now(
     assert before <= event_processor._buffer[0]["timestamp"] <= after
 
 
-def test_track_event_uses_explicit_timestamp(
-    event_processor: EventProcessor,
-) -> None:
-    ts = datetime(2026, 1, 1, 12, 0, 0, tzinfo=timezone.utc)
-
-    event_processor.track_event(event="ping", timestamp=ts)
-
-    assert event_processor._buffer[0]["timestamp"] == int(ts.timestamp() * 1000)
-
-
 def test_track_exposure_event_buffers_with_flag_exposure_event_name(
     event_processor: EventProcessor,
 ) -> None:
@@ -74,16 +64,6 @@ def test_track_exposure_event_buffers_with_flag_exposure_event_name(
     assert "sdk_version" in event["metadata"]
 
 
-def test_track_exposure_event_uses_explicit_timestamp(
-    event_processor: EventProcessor,
-) -> None:
-    ts = datetime(2026, 1, 1, 12, 0, 0, tzinfo=timezone.utc)
-
-    event_processor.track_exposure_event(feature_name="checkout_v2", timestamp=ts)
-
-    assert event_processor._buffer[0]["timestamp"] == int(ts.timestamp() * 1000)
-
-
 def test_auto_flush_on_buffer_full() -> None:
     config = EventProcessorConfig(events_api_url="http://test/", max_buffer_items=5)
     processor = EventProcessor(config=config, environment_key="key")

tests/test_flagsmith.py

@@ -1003,7 +1003,6 @@ def test_track_event_delegates_to_event_processor(
         value=99.5,
         traits={"plan": "premium"},
         metadata={"amount": 99},
-        timestamp=None,
     )
 
 
@@ -1037,7 +1036,6 @@ def test_track_exposure_event_delegates_to_event_processor(
         value="variant_b",
         traits={"plan": "premium"},
         metadata={"source": "homepage"},
-        timestamp=None,
     )
 
 
@@ -1075,7 +1073,6 @@ def test_get_experiment_flag_returns_flag_and_tracks_exposure(
         value="some-value",
         traits={"plan": "premium"},
         metadata=None,
-        timestamp=None,
     )