jKjddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z m Z m Z ddl mZmZmZmZmZmZddlmZmZddlmZddlmZddlmZmZmZmZddl m!Z!dd l"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z-m.Z/m0Z1m2Z2m3Z4m5Z6m7Z8dd l9m:Z:dd l;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGdd lHmIZImJZJmKZKddlLmMZMmNZNmOZOmPZPddlQmRZRmSZSddlTmUZUddlVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZdddlemfZfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqddlrmsZsmtZtmuZumvZvmwZwmxZxddlymzZzddl{m|Z|m}Z}e<dZ~deeeffdZdefdZdZddZGddeZdZy) N)datetime timedeltatimezone)AnyDictListMappingOptionalUnion)UUIDuuid4)Unpack)_BackgroundEventLoopRunner)ID_TYPES ExceptionArgOptionalCaptureArgsOptionalSetArgs)Consumer)_get_current_context,get_capture_exception_code_variables_context)get_code_variables_detect_secrets_context*get_code_variables_ignore_patterns_context(get_code_variables_mask_patterns_context/get_code_variables_mask_url_credentials_contextget_context_device_idget_context_distinct_idget_context_session_idget_tagsidentify_context_scoped new_contextset_context_device_idset_context_sessiontag)ExceptionCapture)_configure_posthog_logging) %DEFAULT_CODE_VARIABLES_DETECT_SECRETS&DEFAULT_CODE_VARIABLES_IGNORE_PATTERNS$DEFAULT_CODE_VARIABLES_MASK_PATTERNS+DEFAULT_CODE_VARIABLES_MASK_URL_CREDENTIALSexc_info_from_errorexception_is_already_capturedexceptions_from_error_tuple handle_in_appmark_exception_as_captured#try_attach_code_variables_to_frames)FeatureFlagEvaluations_EvaluatedFlagRecord_FeatureFlagEvaluationsHost)InconclusiveMatchErrorRequiresServerEvaluationmatch_feature_flag_propertiesresolve_bucketing_value)FlagDefinitionCacheDataFlagDefinitionCacheProvider)Poller)AI_EVENTS_ENDPOINTEVENTS_ENDPOINTAPIErrorQuotaLimitErrorRequestsConnectionErrorRequestsTimeout batch_postdetermine_server_hostflagsget is_ai_eventnormalize_host remote_configreset_sessions) FeatureFlagFeatureFlagErrorFeatureFlagResult FlagMetadataFlagsAndPayloads FlagsResponse FlagValueSendFeatureFlagsOptionsnormalize_flags_responseto_flags_and_payloads to_payloads to_values) FlagCacheRedisFlagCacheSizeLimitedDictcleanguess_timezonesystem_context)VERSION)QueueFulliPreturnct|}|rt|r|dfSt}|r|dfStt dfS)zMReturns the distinct id to use, and whether this is a personless event or notFT) stringify_idlenrstrr )passed stringified context_ids _/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/posthog/client.pyget_identity_statergusHv&Ks;'U##(*JE"" L$ ct|tr t|St|}|st d|d t||S#t$rt d|ddwxYw)NzInvalid event uuid z5. Expected a valid UUID string or uuid.UUID instance.) isinstancer rbr` ValueError)valuerds rf_stringify_event_uuidrms%5zu%K !%*_ `   [  !%*_ `  s AA c|xsi}t}|r?|j}t|j|d<|j ||}d|vrt r t |d<|S)Nz $context_tags $session_id)r collect_tagssetkeysupdater) propertiescurrent_context context_tagss rfadd_context_tagsrwsq!rJ*,O&335 &),*;*;*=&> ?#J'! J&+A+C$:$< =! rhcfd}|S)a' Decorator to prevent raising exceptions from public API methods. Note that this doesn't prevent errors from propagating via `on_error`. Exceptions will still be raised if the debug flag is enabled. Args: default_return: Value to return on exception (default: None) c8ddlm}|fd}|S)Nr)wrapsc |g|i|S#t$rE}|jr||jjdjd|cYd}~Sd}~wwxYw)Nz Error in z: ) Exceptiondebuglog exception__name__)selfargskwargsedefault_returnfuncs rfwrapperz,no_throw..decorator..wrappersb &D242622 &::G""Yt}}oRs#CD%%  &s  A:AAA) functoolsrz)rrzrrs` rf decoratorzno_throw..decorators## t &  &rh)rrs` rfno_throwrs  rhc(eZdZUdZej dZejZ iZ e e e e fejfed<eZee e e fed<dddddd d dd dd d ddddddd d ddddddddddddddddej(ej*ej,df(de deedee dzfdZdZdZdZd{deefdZd{deefdZ de de!ddfdZ"de#e e!ffdZ$de ddfdZ%d e ddfd!Z&d"e ddfd#Z'e(d$Z)e)jTd%Z) d|de+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffd)eed*eee d"ee de e e-ee fffd+Z/ d|de+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffd)eed*eee d"ee de e e ffd,Z0 d|de+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffd)eed*eee d"ee de1fd-Z2 d}dee+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffd)eed*eee d"ee de3fd.Z4 d}dee+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffd)eed*eee d"ee de3fd/Z5e6d0e d1e7e8dee fd2Z9de:fd3Z;e6d1e7e<dee fd4Ze6d1e7e<dee fd5Z=e6 d~d6e d7e d8ee#e e!fd9ee-e>e fd:ee-e e?fd)eedee+dee fd;Z@e6 dde fd:ee d)eedee f d=ZAd>eeBd1e7e8dee fd?ZCeDd@ZEdAZFdBZGddCeeHddfdDZIddEZJddFZKdGZLdHZM ddIeNdJee ddfdKZOdLZPdMZQdNZRddddddOdeSfdPZTddddddddQdRe de+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSedTed)eed"ee deefdUZUde+dRe deeVfdVZWdddddddddWdRe de+dXeeSd&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSedTed)eed"ee deeVfdYZXddddddddQdRe de+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSedTed)eed"ee deeVfdZZYddddddddQdRe de+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSedTed)eed"ee deeSfd[ZZ ddRe de+d&e,e e-e e.ffd'e e e fd(e e e e e!ffd"ee deeSfd\Z[ddddddddd]dRe de+d^eeSd&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSedTed)eed"ee dee\fd_Z] ddRe de+d&e,e e-e e.ffd'e e e fd(e e e e e!ffd)eed"ee de ee^ee ee.effd`Z_ dde+dRe daeeSdbee dced&e,e e-e e.ffd)eeddee deee.dfee^dgee fdhZ`dddide+dRe daeeSd8e e e!fd&ee,e e-e e.ffd)eeddfdjZadRe fdkZbdRe d^eSdee fdlZcddddddddmde+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSed)eed*eee d"ee dee e e-ee fffdnZdddddddddmde+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSed)eed*eee d"ee de1fdoZe dddddddddpdee+d&ee,e e-e e.ffd'ee#e e!fd(ee#e e#e e!ffdSed)eedqeefe d"ee degfdrZhdZieejeds<dejfdtZkddddddude+d&e,e e-e e.ffd*eee d"ee de e1eff dvZldwZmdxZndyZodzZpy)Clientai This is the SDK reference for the PostHog Python SDK. You can learn more about example usage in the [Python SDK documentation](/docs/libraries/python). You can also follow [Flask](/docs/libraries/flask) and [Django](/docs/libraries/django) guides to integrate PostHog into your project. For long-running applications, create one client during application startup and reuse it for the lifetime of the process. This keeps background queues predictable and makes shutdown flushing straightforward. Multiple clients are still supported for intentional multi-project or multi-host setups. Examples: ```python from posthog import Posthog posthog = Posthog('', host='') posthog.debug = True if settings.TEST: posthog.disabled = True ``` posthog_client_registry_duplicate_client_warningsNF'Tdg@project_api_keyflag_definition_cache_providerin_app_modulesc*h,||_t||_|xsdj|_||_||_||_| |_t||_ t||_ d|_ | |_| |_d|_d|_d|_d|_||_||_t-d||_d|_t3t4t6|_||_|j=||_d|_ d|_!||_"d|_#tIjJ|_&|xs |j |_'||_(||_)||_*|)|_+||_,||_-||_.|%|_/|&|_0|'|_1|(|_2d|_3||_4||_5||_6| | ntn|_8|!|!ntr|_:|"|"ntv|_<|#|#ntz|_>|$|_?| tj}||_Ct|tr|jn|xsd|_F|r>tj|jjtjn)|jjtj|js|jjd|j||jZr=t||j^|j`|jb|jd|_3| rd|_Pn|rtj|jg|_Pt| D]n}*t|j|j|j|||| | | ||jV }+|jj|+|s_|+jpttdr.tj|,tj,fd |jy#t$rd}Y'wxYw) a` Initialize a new PostHog client instance. Args: project_api_key: PostHog project API key/token. host: PostHog host. Defaults to the US ingestion endpoint when not set. App hosts such as ``https://us.posthog.com`` are mapped to the corresponding ingestion host. debug: Enable verbose SDK logging and re-raise errors from public API methods. max_queue_size: Maximum number of events buffered before upload. send: If False, queueing succeeds but events are not sent. on_error: Optional callback invoked by background consumers when an upload fails. flush_at: Number of queued events that triggers a batch upload. flush_interval: Maximum seconds a background consumer waits before flushing a partial batch. gzip: Whether to gzip event upload payloads. max_retries: Number of upload retries for background consumers. sync_mode: If True, send each event synchronously instead of using background worker threads. timeout: HTTP request timeout in seconds for event uploads. thread: Number of background consumer threads. poll_interval: Seconds between local feature flag definition refreshes. personal_api_key: Personal API key used for local feature flag evaluation and remote config payloads. disabled: If True, disable captures and API requests. Useful in tests. disable_geoip: Whether to disable server-side GeoIP enrichment. Defaults to True. is_server: Whether events are emitted from a server-side runtime. Defaults to True; set to False when using the SDK as a client/CLI so the device OS is attributed to the person normally. historical_migration: Mark events as historical migration imports. feature_flags_request_timeout_seconds: Timeout in seconds for feature flag and remote config requests. feature_flags_request_max_retries: Number of retries for feature flag requests after network, transport, or timeout failures. Defaults to 1. Set to 0 to disable retries. super_properties: Properties merged into every captured event. enable_exception_autocapture: Automatically capture uncaught exceptions. log_captured_exceptions: Also log exceptions captured by error tracking. project_root: Root path used to determine in-app stack frames for captured exceptions. Defaults to the current working directory. privacy_mode: For AI observability, capture usage metadata without prompt inputs or outputs. before_send: Optional callback that can modify or drop events before upload. Return ``None`` to drop an event. flag_fallback_cache_url: Optional feature flag fallback cache URL, such as ``memory://local/?ttl=300&size=10000`` or a Redis URL. enable_local_evaluation: Whether to poll feature flag definitions for local evaluation when a personal API key is configured. flag_definition_cache_provider: Optional external cache provider for sharing feature flag definitions across workers. capture_exception_code_variables: Capture local variable values on exception stack frames. code_variables_mask_patterns: Variable-name patterns to mask when capturing code variables. code_variables_ignore_patterns: Variable-name patterns to omit when capturing code variables. code_variables_mask_url_credentials: Scrub credentials embedded in URLs/DSNs (e.g. ``user:pass@host``) from captured code variables, regardless of the surrounding variable name. Defaults to True. code_variables_detect_secrets: Last-resort entropy-based detection that redacts high-entropy secret-looking values (API keys, tokens, strong passwords) sitting in innocuously-named variables, after the name and URL checks. Skips structured ids (UUIDs, ObjectIds, hashes). Defaults to True. in_app_modules: Module/package prefixes treated as in-app frames in captured exceptions. enable_exception_autocapture_rate_limiting: Rate limit autocaptured exceptions client-side with a token bucket per exception type. Disabled by default. exception_autocapture_bucket_size: Maximum burst of autocaptured exceptions allowed per exception type (token bucket size, clamped to 0-100). exception_autocapture_refill_rate: Tokens restored per refill interval for each exception type's bucket. exception_autocapture_refill_interval_seconds: Seconds between token refills for autocaptured exception rate limiting. Examples: ```python from posthog import Posthog posthog = Posthog('', host='') ``` Category: Initialization NrzFapi_key is empty after trimming whitespace; check your project API key)rate_limiting_enabled bucket_size refill_raterefill_interval_seconds) hoston_errorflush_atflush_intervalgzipretriestimeouthistorical_migrationdedicated_ai_endpointregister_at_forkc.tjSN)r_reinit_after_fork_weak) weak_selfsrfz!Client.__init__..sv'E'Ei'Prh)after_in_child)]_max_queue_sizer\queuestripapi_keyrr}send sync_moderFraw_hostrBr_duplicate_client_registry_keyrr_feature_flagsfeature_flags_by_keygroup_type_mappingcohorts poll_interval%feature_flags_request_timeout_secondsmax!feature_flags_request_max_retriespollerrW MAX_DICT_SIZErq#distinct_ids_feature_flags_reportedflag_fallback_cache_url_initialize_flag_cache flag_cacheflag_definition_version _flags_etag_flag_definition_cache_provider,_flag_definition_cache_provider_async_runner threadingLock1_flag_definition_cache_provider_async_runner_lockdisabled disable_geoip is_serverr_dedicated_ai_endpointsuper_propertiesenable_exception_autocapturelog_captured_exceptions*enable_exception_autocapture_rate_limiting!exception_autocapture_bucket_size!exception_autocapture_refill_rate-exception_autocapture_refill_interval_secondsexception_capture privacy_modeenable_local_evaluation capture_exception_code_variablesr)code_variables_mask_patternsr(code_variables_ignore_patternsr*#code_variables_mask_url_credentialsr'code_variables_detect_secretsrosgetcwdr| project_rootrjrbpersonal_api_keylogging basicConfigr~setLevelDEBUGWARNINGerror_set_before_sendr% consumersatexitregisterjoinrangerappendstarthasattrweakrefrefr_warn_if_duplicate_async_client)-rrrr}max_queue_sizerrrrr max_retriesrrthreadrrrrrrrrrrrrr before_sendrrrrrrrrrrrrrr_consumerrs- @rf__init__zClient.__init__sP .!.1 (-2446     "&t, )$/ IM+   ?C!<@15 * 1 225 02 .)- 3B=RU3V0'>$556MN'($*./M,  9BKAQ> 4 $4 *"$8!'=# 0,H)'>$ 6 72S.1R. 9 :"&('>$0P-,7 )5 ).9 +7 +3> 0< 0-8 *6 * -   $!yy{ ) *C0  " " $!!      ! HH  gmm , HH  goo .|| HHNNX  k*  , ,%5&*&U&U BB BB(,(Z(Z &D " !DN *DN6]#JJLL%%#1'#)=*.*E*E %%h/NN$%#( 2) * D)I   P  ,,.U $#  $s5P"" P10P1c:|js$|jr|js |jsy|j|jf}d}t j 5t jj|tj}t|dkD}|j|||_ |r3|t jvr!t jj|d}ddd|r|jj!dyy#1swY(xYw)NFrTzMultiple active PostHog clients detected for the same project API key and host. Reuse one Posthog instance per app or process when possible to avoid competing background queues and missed shutdown flushes. Multiple clients are supported when intentional.)rrrrrr_client_registry_lockr setdefaultrWeakSetraaddrrr~warning)r registry_key should_warnclientshas_existing_clients rfrz&Client._warn_if_duplicate_async_client s == T^^4<<  dii0   ) )--88goo/G#&g,"2  KK 2>D /$ (I(II1155lC" *  HH  $  * )s BDDcB|j}|ytj5tjj |}|C|j ||s0tj|=tj j |d|_dddy#1swYyxYwr)rrrrrDdiscardr)rrrs rf_unregister_duplicate_clientz#Client._unregister_duplicate_client(s::     ) )--11,?G"%// =55==lK26D /* ) )s A,BBc|6t|r||_y|jjdd|_yd|_y)Nz/before_send is not callable, it will be ignored)callablerr~r)rrs rfrzClient._set_before_send7s;  " $#.   !RS#' #D rhcapture_exceptionsct|||S)au Create a new context for managing shared state. Learn more about [contexts](/docs/libraries/python#contexts). Args: fresh: Whether to create a fresh context that doesn't inherit from parent. capture_exceptions: Whether to automatically capture exceptions in this context. If omitted, defaults to this client's exception autocapture setting. Examples: ```python with client.new_context(): client.identify_context('') client.capture('event_name') ``` Category: Contexts freshr client)r!rrr s rfr!zClient.new_contextAs$,>t  rhct|||S)a Decorator that creates a new context for the wrapped function using this client. Args: fresh: Whether to create a fresh context that doesn't inherit from parent. capture_exceptions: Whether to automatically capture exceptions in this context. If omitted, defaults to this client's exception autocapture setting. Category: Contexts r)_context_scopedrs rfscopedz Client.scopedWs,>t  rhnamerlr^ct||y)z Add a tag to the current context. Args: name: The tag key. value: The tag value. Category: Contexts N) _context_tag)rrrls rfr$z Client.taggs T5!rhctS)z Get all tags from the current context. Returns: Dict of all tags in the current context. Category: Contexts )_context_get_tagsrs rfrzClient.get_tagsts !""rh distinct_idct|y)z Identify the current context with a distinct ID. Args: distinct_id: The distinct ID to associate with the current context and its children. Category: Contexts N)_context_identify_context)rrs rfrzClient.identify_contexts  "+.rh session_idct|y)z Set the session ID for the current context. Args: session_id: The session ID to associate with the current context and its children. Category: Contexts N)_context_set_context_session)rrs rfr#zClient.set_context_sessions  %Z0rh device_idct|y)z Set the device ID for the current context. Args: device_id: The device ID to associate with the current context and its children. Category: Contexts N)_context_set_context_device_id)rr!s rfr"zClient.set_context_device_ids  'y1rhc|jS)z9 Get the local evaluation feature flags. )rrs rf feature_flagszClient.feature_flagss """rhc|xsg|_|jDcic]}|jd|d|c}|_|jJdycc}w)z9 Set the local evaluation feature flags. keyNDfeature_flags_by_key should be initialized when feature_flags is set)rrDr)rrCflags rfr%zClient.feature_flagssr $kr++% +xx* K +% ! ((4 R 4 % sAgroupsperson_propertiesgroup_propertiesrflag_keys_to_evaluatec P|j|||||||}t|xsiS)a Get feature flag variants for a user. Args: distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. disable_geoip: Whether to disable GeoIP for this request. flag_keys_to_evaluate: A list of specific flag keys to evaluate. If provided, only these flags will be evaluated, improving performance. device_id: The device ID for this request. Category: Feature flags r!)get_flags_decisionrT rrr*r+r,rr-r! resp_datas rfget_feature_variantszClient.get_feature_variantss@4++      !, #)r)rhc P|j|||||||}t|xsiS)a Get feature flag payloads for a user. Args: distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. disable_geoip: Whether to disable GeoIP for this request. flag_keys_to_evaluate: A list of specific flag keys to evaluate. If provided, only these flags will be evaluated, improving performance. device_id: The device ID for this request. Examples: ```python payloads = posthog.get_feature_payloads('') ``` Category: Feature flags r/)r0rSr1s rfget_feature_payloadszClient.get_feature_payloadss@>++      !, 9%++rhc H|j|||||||}t|S)a Get feature flags and payloads for a user. Args: distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. disable_geoip: Whether to disable GeoIP for this request. flag_keys_to_evaluate: A list of specific flag keys to evaluate. If provided, only these flags will be evaluated, improving performance. device_id: The device ID for this request. Examples: ```python result = posthog.get_feature_flags_and_payloads('') ``` Category: Feature flags r/)r0rR) rrr*r+r,rr-r!resps rfget_feature_flags_and_payloadsz%Client.get_feature_flags_and_payloads s;>&&      !' %T**rhc  |j|||||||S#t$r1}|jjd|t icYd}~Sd}~wwxYw)a Get feature flags decision. Args: distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. disable_geoip: Whether to disable GeoIP for this request. flag_keys_to_evaluate: A list of specific flag keys to evaluate. If provided, only these flags will be evaluated, improving performance. device_id: The device ID for this request. Examples: ```python decision = posthog.get_flags_decision('user123') ``` Category: Feature flags r/zUnable to get feature flags: %sN)_get_flags_decisionr|r~rrQ) rrr*r+r,rr-r!errs rfr0zClient.get_flags_decision3sf> 0++! %#,  0 HH  @# F+B/ / 0s A&A AAcN|jr tiS|xsi}|xsi}|xsi}| t}| t}| |j}|si}||||||d}|r||d<t |j |jf|j|jd|} t| S)N)rr*r+r, geoip_disabler!r-)rr) rrQrrrrCrrrr) rrr*r+r,rr-r! request_datar2s rfr:zClient._get_flags_decision`s ==+B/ /2-3+1r  13K  -/I   ..MF'!2 0*" (  !4IL0 1 LL II >>>>    ( 22rheventrc .|jdd}|jdd}|jdd}|jdd}|jdd}|jdd}|jdd } |jd d} i|xsit}t|}|Jt|\}} | r d |vrd |d <|||||d } |r||d <i} |/| r|jj d|j } n1i}|j| }|drtjdtd |ddur&|j||xsi|d|d| d|d}nz|dd ur!|j|||d|d| |d}nR|jr&|j||xsi|d|d| d|d}n |j|||d|d| |d}|xsij!D] \}}|| d|<|xsij!Dcgc] \}}|d ur| }}}|r|| d<| r i| |}|| d<|j#| | S#t$r(}|jjd|Yd}~d}~wwxYwcc}}w)a Captures an event manually. [Learn about capture best practices](https://posthog.com/docs/product-analytics/capture-events) Args: event: The event name to capture. distinct_id: The distinct ID of the user. properties: A dictionary of properties to include with the event. timestamp: The timestamp of the event. uuid: A unique identifier for the event. If provided, it must be a valid UUID string or uuid.UUID instance; invalid values are ignored and replaced with a newly generated UUID. groups: A dictionary of group information. flags: A FeatureFlagEvaluations snapshot from evaluate_flags(). The exact values from the snapshot are attached with no extra /flags request. send_feature_flags: Deprecated. Prefer flags=... from evaluate_flags(). When truthy, evaluates flags during capture and attaches them to the event. disable_geoip: Whether to disable GeoIP for this event. Examples: ```python # Anonymous event posthog.capture('some-anon-event') ``` ```python # Context usage from posthog import identify_context, new_context with new_context(): identify_context('distinct_id_of_the_user') posthog.capture('user_signed_up') posthog.capture('user_logged_in') posthog.capture('some-custom-action', distinct_id='distinct_id_of_the_user') ``` ```python # Set event properties posthog.capture( "user_signed_up", distinct_id="distinct_id_of_the_user", properties={ "login_type": "email", "is_free_trial": "true" } ) ``` ```python # Page view event posthog.capture('$pageview', distinct_id="distinct_id_of_the_user", properties={'$current_url': 'https://example.com'}) ``` Category: Capture rNrt timestampuuidr*rCsend_feature_flagsFrz$process_person_profile)rtrArr?rBz$groupsz[FEATURE FLAGS] Both `flags` and `send_feature_flags` were passed to capture(); using `flags` and ignoring `send_feature_flags`. should_sendu`send_feature_flags` is deprecated and will be removed in a future major version. Pass a `flags` snapshot from `posthog.evaluate_flags(...)` instead — it avoids a second `/flags` request per capture and guarantees the event carries the exact flag values your code branched on. stacklevelonly_evaluate_locallyTr+r,flag_keys_filter)r*r+r,rrHr-)r+r,rr-z0[FEATURE FLAGS] Unable to get feature variants: $feature/z$active_feature_flags)rDrZrwrgr~r_get_event_properties_parse_send_feature_flagswarningswarnDeprecationWarning get_all_flagsr3r%r|ritems_enqueue)rr?rrrtrArBr*flags_snapshotrCr personlessmsgextra_propertiesfeature_variants flag_optionsrfeaturevariantr'rlactive_feature_flagss rfcapturezClient.capturesrjj5 ZZ d3 JJ{D1 zz&$'Hd+GT2#ZZ(? %j1 %%%$6{$C!j 3:E49J0 1%"&   $*Jy !+-  %!  R .CCE FH  99:LMLM* K' .#$;<D+/+=+='$*Lb.:;N.O-9:L-M*7262>?Q2R,>,(&&=>%G+/+D+D'".:;N.O-9:L-M*72>?Q2R ,E,(+++/+=+='$*Lb.:;N.O-9:L-M*7262>?Q2R,>,(,0+D+D'".:;N.O-9:L-M*72>?Q2R ,E,(&6%;$B$B$D :A 9WI!67%E &6%;$B$B$D$$DLS%%$D !$ $%7{$C!j  +$#$&   " #/23I3K/LC m ,}}S-00rhrc |jdd}|jdd}|jdd}|jdd}|jdd} |xsi}|'t|r|jjdy| t |}nt j }||d k(r|jjd yt|} td d | ii|j|j } | d d } d| i|}t} t} t}t}t!}| | n |j"}| | n |j$}||n |j&}||n |j(}||n |j*}|rt-| ||||||j.r|jj1|||jdd}|jdd}|jdd}|j3d|||||||| }|| t5|||S#t6$r(}|jj1d|Yd}~yd}~wwxYw)ay Capture an exception for error tracking. Args: exception: The exception to capture. distinct_id: The distinct ID of the user. properties: A dictionary of additional properties. flags: A ``FeatureFlagEvaluations`` snapshot from ``evaluate_flags()``. Attaches those exact flag values to the captured `$exception` event. send_feature_flags: Deprecated. Pass ``flags`` from ``evaluate_flags()`` instead. disable_geoip: Whether to disable GeoIP for this event. Examples: ```python try: # Some code that might fail pass except Exception as e: posthog.capture_exception(e, 'user_distinct_id', properties=additional_properties) ``` Category: Error Tracking rNrtrCrCFrz$Exception already captured, skippingNNNz"No exception information availablervalues)in_app_includerz$exception_list) mask_patternsignore_patternsmask_url_credentialsdetect_secrets)extrarArBr*z $exception)rrtrArBr*rCrCrzFailed to capture exception: )rDr,r~r}r+sysexc_inforr-r.rrrrrrrrrrrrr0rrr\r/r|)rrrrrtrSrCrr|all_exceptions_with_tracer?$all_exceptions_with_trace_and_in_appcontext_enabled context_maskcontext_ignorecontext_mask_url_credentialscontext_detect_secretsenabledrvrwrxryrArBr*resrs rfcapture_exceptionzClient.capture_exception@s:jj5 ZZ d3 GT2#ZZ(8/A#A  !EF)DH(M %" ";" $22!..E493Eh3O 0"#GJ KLOCELGIN?A )&O%P "#. ::  +66 "-88 0;-== !*5'77  38"/$3)=#1 ++""9F"; ;5I::fd+DZZ$/F,,'%#$#5+ C$*9c:J  HH  !>qcB C s&.H/ AH/EH// I 8II c8|}|y|jy)zk Reinitialize the client after a fork. Garbage collected if the client is deleted. N)_reinit_after_fork)rrs rfrzClient._reinit_after_fork_weaks { <  !rhcl|jrt|j|_g}|jD]}t |j|j |j |j|j|j|j|j|j|j|j }|j||j s|j#||_|j$rKt't)|j*|j,|_|j.j#nd|_d|_t3j4|_t9|j:t<r |j?|j@|_tCy)a5Reinitialize fork-unsafe client state in a forked child process. Registered via os.register_at_fork(after_in_child=...) so it runs exactly once in each child, before any user code, covering all code paths (capture, flush, join, etc.). Python threads do not survive fork() and queue.Queue internal locks may be in an inconsistent state, so the event queue, consumer threads and other state are replaced. Inherited queue items are not retained as they'll be handled by the parent process's consumers. ) rrrrrrrrrsecondsintervalexecuteN)"rr\rrrrrrrrrrrrrrrrrr:rr_load_feature_flagsrrrrrrjrrVrrrH)r new_consumersoldrs rfrzClient._reinit_after_forksD >>t334DJM~~#JJKK \\ \\##5KKKK),)A)A*-*C*C $$X.99NN$#&&+DN  ' ' "4+=+=>00DK KK   DK=A9AJAQ> doo~ 6"99$:V:VWDOrhc 4|jry|d}|$tjtj}t |}|j |d<d|vr"|jd}| t||d<d|vrtt|d<|d}|jdsi|d<d|dd<t|dd <| |j }|rd |dd <|j"ri|d|j"|d<|j$rd |dd <t|jd d|d <t'|}|j(r2 |j)|}||jj+dy|}|jj+d||j0s|S|j2r|jj+d|d|j4r t7|jdrt8nt:}t=|j>|j@|jB|jD|g|jF||S |jHjK|d|jj+d|d|S#t$r'}|jjd|Yd}~6d}~wwxYw#t,$r)}|jj/d|Yd}~md}~wwxYw#tL$r|jjOdYywxYw)z8Push a new `msg` onto the queue, return `(success, msg)`NrAtzrBz$%s Falling back to a generated UUID.rtzposthog-pythonz$libz $lib_versionTz$geoip_disablez $is_serverrz%Event dropped by before_send callbackzError in before_send callback: z queueing: %szenqueued with blocking %s.r?)rrbatchrpathF)blockz enqueued %s.zanalytics-python queue is full)(rrnowrutcrY isoformatpoprmrkr~rr`r rDr[rrrrXrr}r|rrrrrEr;r<rArrrrrrputr]r) rrUrrArBr sent_uuid modified_msgrs rfrRzClient._enqueues == $    5I#9- $..0K S=776?DN"7"=CK  &uw/CKK ww|$ "C $4L&!,3L.)   ..M 26C . /  N3|#4 N8M8M NC  >>.2C l +)#''-*FGMCj    J#//4 'HHNN#JK" ~s+yy  >> HHNN7W F..;swww?O3P#$    YY e%)%>%>    JJNN3eN , HHNN>3w< 8 O"NHHNN#I1MMNN J""%DQC#HII JB  HH  = > sH/J .J;9J; =K0 J8J33J8; K-K((K-0$LLtimeout_secondscr|j}|j} ||jntj|z}|j 5|j ru|tjz }|dkr1|jjd||j  dddy|j j||j ruddd|jjd|y#1swY&xYw#t$r&}|jjd|Yd}~yd}~wwxYw)a Force a flush from the internal queue to the server. Do not use directly, call `shutdown()` instead. Args: timeout_seconds: Maximum seconds to wait for the queue to flush. Defaults to 10 seconds. Pass ``None`` to wait indefinitely. Examples: ```python posthog.capture('event_name') posthog.flush() # Ensures the event is sent immediately ``` Nrz7flush timed out after %s seconds with %s items pending.zerror flushing queue: %sz$successfully flushed about %s items.) rqsizertime monotonicall_tasks_doneunfinished_tasksr~rwaitr|rr})rrrsizedeadline remainingrs rfflushz Client.flushts {{} & >>+o=))00$,t~~/?$? $> HH,, Y / % 6 6 #*),,11)< 00* =tD!*)  HH  91 =  s<6DAC;%D.'C;D;DD D6D11D6c*|jr2|jD]#}|j |j%|jr|jj |j |jy#t$rYxwxYw)z End the consumer thread once the queue is empty. Do not use directly, call `shutdown()` instead. Examples: ```python posthog.join() ``` N)rpauser RuntimeErrorrstop(_shutdown_flag_definition_cache_providerr )rrs rfrz Client.joinsx >> NN MMO+ ;; KK    557 ))+$sB BBc|jd|j|jj|jr|jj yy)z Flush all messages and cleanly shutdown the client. Call this before the process ends in serverless environments to avoid data loss. Examples: ```python posthog.shutdown() ``` N)r)rrrclearrclosers rfshutdownzClient.shutdownsM 4 (  00668  ! !  " " ( ( * "rhctj|s|S|j5|jt |_|jj |cdddS#1swYyxYwr)inspect isawaitablerrrrun)rresults rf._resolve_flag_definition_cache_provider_resultz5Client._resolve_flag_definition_cache_provider_results[""6*M  C C@@H.0ADDHHP D C Cs 6A$$A-c|jsy |j|jj|j 5|jr!|jjd|_dddy#t$r(}|jj d|Yd}~od}~wwxYw#1swYyxYw#|j 5|jr!|jjd|_dddw#1swYwxYwxYw)Nz/[FEATURE FLAGS] Cache provider shutdown error: ) rrrr|r~rrrr)rrs rfrz/Client._shutdown_flag_definition_cache_providers33  M  ? ?44==?  GGDDEEKKMHLDEHG R HHNNLQCP Q Q RHGGGDDEEKKMHLDEHGGsM)A;.B/; B,B'"B;'B,,B;/B8; D .C?6 D ?D D dataold_flags_by_keyc|d|_|d|_|d|_|jrT|Q||jxsik7r=|j }|xj dz c_|jj |yyyy)zVUpdate internal flag state from cache data and invalidate evaluation cache if changed.rCrrNr)r%rrrrrinvalidate_version)rrr old_versions rf_update_flag_statezClient._update_flag_states"']"&';"<I  OO , T%>%>%D"E66K  ( (A - ( OO . .{ ; F- rhcd}|jr* |j|jj}|s|jr |j|jj }|rf|jjd|j||jxsitjtj|_y|js|jjdd}|r|j!yy#t$r+}|jj d|d}Yd}~ d}~wwxYw#t$r*}|jj d|d}Yd}~yd}~wwxYw)NTz3[FEATURE FLAGS] Cache provider should_fetch error: zA[FEATURE FLAGS] Using cached flag definitions from external cacherrzJ[FEATURE FLAGS] Cache empty and no flags loaded, falling back to API fetchz*[FEATURE FLAGS] Cache provider get error: )rrshould_fetch_flag_definitionsr|r~rget_flag_definitionsr}rrrrrr_last_feature_flag_pollr%_fetch_feature_flags_from_api)r should_fetchr cached_datas rfrzClient._load_feature_flagss`  / / $#RR88VVX   D D $"QQ88MMO HHNN[++#d6O6O6USU,4<<<8<<3PD0 --h(,   . . 0 G $I!M $  $< $!KA3OP#  $s6)DBE )E  E  EE  F E;;Fc|j}||jjdy |jxsi}t |d|j d|j d|j}|j|_|jrE|jjdtjtj|_y|j |jj#d y|j%|j | |j&rY |j)|j&j+|j,xsg|j.xsi|j0xsid tjtj|_y#t2$r(}|jj#d |Yd}~Vd}~wwxYw#t4$r6}|j6d k(rd|j8d}|jj#d|g|_i|_i|_|j:r|j:j=|jrt5d ||j6dk(ro|jjdg|_i|_i|_|j:r|j:j=|jr+t5dd|jj#d|Yd}~d}~wt2$rN}|jjd|j>z|jj|Yd}~d}~wwxYw)z)Fetch feature flags from the PostHog API.NL[FEATURE FLAGS] You have to specify a personal_api_key to use feature flags.z/flags/definitions?token=z &send_cohorts )retagz;[FEATURE FLAGS] Flags not modified (304), using cached datarzB[FEATURE FLAGS] Unexpected empty response data in non-304 responser)rCrrz,[FEATURE FLAGS] Cache provider store error: izError loading feature flags: zw. Please verify both your project_api_key and personal_api_key. More information: https://posthog.com/docs/api/overviewz[FEATURE FLAGS] %s)statusmessageiz[FEATURE FLAGS] PostHog feature flags quota limited, resetting feature flag data. Learn more about billing limits at https://posthog.com/docs/billing/limits-alertsz#PostHog feature flags quota limitedz-[FEATURE FLAGS] Error loading feature flags: z`[FEATURE FLAGS] Fetching feature flags failed with following error. We will retry in %s seconds.) rr~rrrDrrrr not_modifiedr}rrrrrrrrrron_flag_definitions_receivedr%rrr|r=rrrrr)rrrresponserdetails rfrz$Client._fetch_feature_flags_from_apis00  # HH  ^  Y 040I0I0OR  +DLL>G %% H (}}D $$Q08||x||/L,}}$X  # #HMMDT # U33 WGG<<YY)-););)Ar6:6M6M6SQS+/<<+=2r(0||x||'D$a!WHHNN%QRSQT#UVVW$ Txx33AII;?NN 3V<%'"*,'! ??OO))+::"#v>>S  {&("*,'! ??OO))+::"" E !NqcRS HH  r$$%  HH  Q    sWB#G'G8)G"AF$$ G-G GGG M-"D+L M-AM((M-c|jrg|_y|js#|jj dg|_y|j |j rr|jr|jjsKtt|j|j |_|jjyyy)z Load feature flags for local evaluation. Examples: ```python posthog.load_feature_flags() ``` Category: Feature flags Nrrr) rr%rr~rrrris_aliver:rrrrs rfload_feature_flagszClient.load_feature_flagss ==!#D  $$ HH  ^ "$D     "  ' ' KKDKK002 "4+=+=>00DK KK    3 (rhr*r+r,warn_on_unknown_groupsr!c "|xsi}|xsi}|xsi}i}|jddr td|jdsy|jdxsi} | jd} |jxsi} | | jt| } | s/|jj d| d|d td | |vrH|r#|jj d |d d y|jj d |d d y| |vrtd | d|| } || }t||| |j|j|||| || St|||}t||||j|j|||| || S)Nensure_experience_continuityFz&Flag has experience continuity enabledactivefiltersaggregation_group_type_indexz)[FEATURE FLAGS] Unknown group type index z for feature flag r'z!Flag has unknown group type indexz2[FEATURE FLAGS] Can't compute group feature flag: z without group names passed inz(Flag has no group properties for group '')cohort_properties flags_by_keyevaluation_cacher!bucketing_valuerr*r,) rDr4rrbr~rr}r6rrr7)r feature_flagrr*r+r,rr!r flag_filtersrr group_namefocused_group_propertiesrjrs rf_compute_flag_locallyzClient._compute_flag_locallys!2-3+1r<>   :E B()QR R)#'' 28b '3'7'78V'W$!44: ' 3+//4P0QRJ  ?@\?]]op|~CqDpEF--PQQ'*HH$$L\Z_M`LaaAHHNNL\Z_M`LaaA!11,>zl!L(8 'C $z*I0("&,,!66!1# )#5!1  6k9O1!"&,,!66!1# /#5!1  rhr*r+r,rHsend_feature_flag_eventsrr!r'rHrc tjdtd|j|||||||||  } | r| j nd} | yt | S)a3 Check if a feature flag is enabled for a user. Args: key: The feature flag key. distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. only_evaluate_locally: Whether to only evaluate locally. send_feature_flag_events: Whether to send feature flag events. disable_geoip: Whether to disable GeoIP for this request. device_id: The device ID for this request. Examples: ```python is_my_flag_enabled = posthog.feature_enabled('flag-key', 'distinct_id_of_your_user') if is_my_flag_enabled: # Do something differently for this user # Optional: fetch the payload matched_flag_payload = posthog.get_feature_flag_payload('flag-key', 'distinct_id_of_your_user') ``` Category: Feature flags u`feature_enabled` is deprecated and will be removed in a future major version. Use `posthog.evaluate_flags(distinct_id, ...)` and call `flags.is_enabled(key)` instead — this consolidates flag evaluation into a single `/flags` request per incoming request.rErFrN)rMrNrO_get_feature_flag_result get_valuer_) rr'rr*r+r,rHrrr! flag_resultrs rffeature_enabledzClient.feature_enabledswN      33  /-"7%='4  /:;((*t  H~rhc|jr>|jj||}|r |jjd||Sy)z?Returns a stale cached flag value if available, otherwise None.z2[FEATURE FLAGS] Using stale cached value for flag N)rget_stale_cached_flagr~info)rrr' stale_results rf_get_stale_flag_fallbackzClient._get_stale_flag_fallbackAsI ????@@cRL HN$#rhoverride_match_valuer*r+r,rHrrr!rc |jry|j|xsi|xsi|xsi\}}|xsi}|xsi}|xsi}d} d} d} d}d}| t} |j||}|j |||||| }|du}|rm|xs|}||j ||nd}t j|||} |jr9| r6|jj||| |jn |r(|j|jjdn |j|||||| | \} } }}g}|r|jt j"| |jt j$|rdj'|}t j(| |} |jr*| r(|jj||| |j|jj+d|d| |r;|jG||| r| jInd| r | jJnd||| | || | | S#t,$rJ}|jjd|t j.}|j1||} Yd}~d}~wt2$rJ}|jjd|t j4}|j1||} Yd}~d}~wt6$rK}|jjd|t j8}|j1||} Yd}~0d}~wt:$rZ}|jjd |t!j<|j>}|j1||} Yd}~d}~wt@$rK}|jjCd |t jD}|j1||} Yd}~d}~wwxYw) Nz[FEATURE FLAGS] Local evaluation called but feature flag definitions are not loaded yet. Returning None. You can call load_feature_flags() to load flags explicitly.r/,z&Successfully computed flag remotely: #z -> #&[FEATURE FLAGS] Quota limit exceeded: z#[FEATURE FLAGS] Request timed out: z"[FEATURE FLAGS] Connection error: zEATURE FLAGS] API error: z-[FEATURE FLAGS] Unable to get flag remotely: )&r&_add_local_person_and_group_propertiesr'_person_properties_for_local_evaluation_locally_evaluate_flag_compute_payload_locallyrKfrom_value_and_payloadrset_cached_flagrr%r~r%_get_feature_flag_details_from_serverrrJERRORS_WHILE_COMPUTING FLAG_MISSINGrfrom_flag_detailsr}r> QUOTA_LIMITEDrr@TIMEOUTr?CONNECTION_ERRORr= api_errorrr|r UNKNOWN_ERROR_capture_feature_flag_calledrpayload)rr'rrr*r+r,rHrrr!r flag_details request_id evaluated_atfeature_flag_errorlocal_person_properties flag_valueflag_was_locally_evaluatedlookup_match_valuererrors_while_computingerrorsrs rfrzClient._get_feature_flag_resultNs ==  7 7 "!'R &B  ,+2-3+1r    ,0  -/I"&"N"N *# 00    #    &0t%;" %!5!C &1--c3EF  ,BB'K ;//k43O3O#!!)  b 4 N>>#)(%"+?O j,8N)MM"2"I"IJ'MM"2"?"?@),&)9&/AA "6 ??{OO33#S+t7S7Sqc!BC%5%?%?%I"";;KM  N""%RSTRU#VW%5%C%C"";;KM  NsNC!H>> O'AJ  O'AK O')AL// O';AN O'AO""O'c 6|j|||||||||  S)a{ Get a FeatureFlagResult object which contains the flag result and payload for a key by evaluating locally or remotely depending on whether local evaluation is enabled and the flag can be locally evaluated. This also captures the `$feature_flag_called` event unless `send_feature_flag_events` is `False`. Examples: ```python flag_result = posthog.get_feature_flag_result('flag-key', 'distinct_id_of_your_user') if flag_result and flag_result.get_value() == 'variant-key': # Do something differently for this user # Optional: fetch the payload matched_flag_payload = flag_result.payload ``` Args: key: The feature flag key. distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. only_evaluate_locally: Whether to only evaluate locally. send_feature_flag_events: Whether to send feature flag events. disable_geoip: Whether to disable GeoIP for this request. device_id: The device ID for this request. Returns: Optional[FeatureFlagResult]: The feature flag result or None if disabled/not found. r)r) rr'rr*r+r,rHrrr!s rfget_feature_flag_resultzClient.get_feature_flag_results8R,,  /-"7%='-  rhc tjdtd|j|||||||||  } | r| j SdS)au Get multivariate feature flag value for a user. Args: key: The feature flag key. distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. only_evaluate_locally: Whether to only evaluate locally. send_feature_flag_events: Whether to send feature flag events. disable_geoip: Whether to disable GeoIP for this request. device_id: The device ID for this request. Examples: ```python enabled_variant = posthog.get_feature_flag('flag-key', 'distinct_id_of_your_user') if enabled_variant == 'variant-key': # replace 'variant-key' with the key of your variant # Do something differently for this user # Optional: fetch the payload matched_flag_payload = posthog.get_feature_flag_payload('flag-key', 'distinct_id_of_your_user') ``` Category: Feature flags u`get_feature_flag` is deprecated and will be removed in a future major version. Use `posthog.evaluate_flags(distinct_id, ...)` and call `flags.get_flag(key)` instead — this consolidates flag evaluation into a single `/flags` request per incoming request.rErFrN)rMrNrOrr) rr'rr*r+r,rHrrr!feature_flag_results rfget_feature_flagzClient.get_feature_flag skN      #;;  /-"7%='<  3F",,.O4Orhc$|j|jr|jd}|jrk|jJd|jj |}|r; |j ||||||}|j jd|d||S|S#ttf$r,} |j jd|d| Yd} ~ |Sd} ~ wt$r)} |j jd| Yd} ~ |Sd} ~ wwxYw)Nr()r*r+r,r!z$Successfully computed flag locally: z -> zFailed to compute flag z locally: z7[FEATURE FLAGS] Error while computing variant locally: ) r%rrrrDrr~r}r5r4r|r) rr'rr*r+r,r!rr)rs rfrzClient._locally_evaluate_flagS s8    %$*?*?  # # %   ,,8 V 8,,005D#99#%*;)9"+ : HHHNN>se4zRx 12HIQHHNN%    $ MMo"  #;;  !,/-"7%='<  /B"**KtKrhc |j||||||g|}|jd} |jd} |jdd} |jd} | r| j|nd} | | | | fS)z Calls /flags and returns the flag details, request id, evaluated at timestamp, and whether there were errors while computing flags. )r-r! requestId evaluatedAterrorsWhileComputingFlagsFrCN)r:rD)rr'rr*r+r,rr!r2r r rrCr s rfrz,Client._get_feature_flag_details_from_server s,,     #&%- ]];/  }}]3 !*/JE!R g&).yuyy~D Z7MMMrhrrrr r r r c  d|d|d|d||i} ||| d<|r|| d<| r| | d<t| tr| jr/| jjr| jj| d<t| jt r^| jj r| jj | d <| jjr| jj| d <| r| | d <|j|||| || y) Nz $feature_flagz$feature_flag_responselocally_evaluatedrJz$feature_flag_payloadz$feature_flag_request_idz$feature_flag_evaluated_atz$feature_flag_reasonz$feature_flag_versionz$feature_flag_idz$feature_flag_error)rr'rrtr*r) rjrIreason descriptionmetadatarLversionid&_capture_feature_flag_called_if_needed) rrr'rrrr*rr r r r rts rfrz#Client._capture_feature_flag_called s S $h !;u x &   29J. / 5?J1 2 7CJ3 4 lK 0""|':':'F'F5A5H5H5T5T 12,//>((00:F:O:O:W:WJ67((++5A5J5J5M5MJ12 0BJ, - 33#!' 4 rh)r*rc4|r)ttd|jDnd}|||f}|jj |} | t } | |j|<|| vry|j d|||xsi|| j|y)aFire a ``$feature_flag_called`` event if the (distinct_id, flag, response, groups) tuple hasn't already been reported on this client. Group context is included so that group-scoped flags fire a separate event for each group a user is evaluated under. Shared by the single-flag evaluation path and ``FeatureFlagEvaluations.is_enabled() / get_flag()`` so both paths dedupe identically. c3NK|]\}}t|t|fywr)rb).0kvs rf z@Client._capture_feature_flag_called_if_needed..) s"Enda#a&#a&)ns#%rNz$feature_flag_called)rrtr*r)tuplesortedrQrrDrqr\r) rrr'rrtr*r groups_keyfeature_flag_reported_keyreported_flagss rfr'z-Client._capture_feature_flag_called_if_needed s$KQE&EfllnEE FVX &)(J$?!AAEEkR  ! UNDRD 4 4[ A $ 6  "#![FEATURE FLAGS] Unable to get decrypted feature flag payload: ) rrr~rrGrrrr|r)rr'rs rfget_remote_config_payloadz Client.get_remote_config_payload> s& ==  ( HH  r   %%  BB    HH  PQRPST   s7A// B 8BB cd}|j|S|jj|}|r[|jdxsi}|jdxsi}t|tr|rdn t |}|j|d}|S)Nrpayloadstrue)rrDrjr_rb)rr'rrflag_definitionr flag_payloads lookup_values rfrzClient._compute_payload_locallyg s  $ $ ,N3377< *..y9?RL(,,Z8>BM k40[%  $'' d;Grhr*r+r,rHrr-r!c >|j||||||||} | dS)a< Get all feature flags for a user. Args: distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. only_evaluate_locally: Whether to only evaluate locally. disable_geoip: Whether to disable GeoIP for this request. flag_keys_to_evaluate: A list of specific flag keys to evaluate. If provided, only these flags will be evaluated, improving performance. device_id: The device ID for this request. Examples: ```python posthog.get_all_flags('distinct_id_of_your_user') ``` Category: Feature flags r; featureFlags)get_all_flags_and_payloads) rrr*r+r,rHrr-r!rs rfrPzClient.get_all_flags} s?D22 /-"7'"73  ''rhc |jrdddS|j|||\}}| t}|xsi}|j||} |j ||| |||\} } | r&|s$ |j |||||||} t | S| S#t$r)} |jjd| Yd} ~ | Sd} ~ wwxYw)a\ Get all feature flags and their payloads for a user. Args: distinct_id: The distinct ID of the user. groups: A dictionary of group information. person_properties: A dictionary of person properties. group_properties: A dictionary of group properties. only_evaluate_locally: Whether to only evaluate locally. disable_geoip: Whether to disable GeoIP for this request. flag_keys_to_evaluate: A list of specific flag keys to evaluate. If provided, only these flags will be evaluated, improving performance. device_id: The device ID for this request. Examples: ```python posthog.get_all_flags_and_payloads('distinct_id_of_your_user') ``` Category: Feature flags Nr=featureFlagPayloads)r*r+r,r-r!r*r+r,rr-r!z:[FEATURE FLAGS] Unable to get feature flags and payloads: ) rrrr#_get_all_flags_and_payloads_locallyr:rRr|r~r)rrr*r+r,rHrr-r!r rfallback_to_flagsdecide_responsers rfr>z!Client.get_all_flags_and_payloads s"D ==$(F F  7 7)+;  ,+  -/I2"&"N"N *# '+&N&N 5-"7 'O' ## %: "&":":!&7%5"/*?'#;#-_==   ""PQRPST  s+"B CB==C)r*r+r,rHr flag_keysr!rFc |j} | t}| t}|r |jrt | diS|j |xsi|xsi|xsi\}}|xsi}i} d} d} d} d}t }|j||}|j|t||||\}}|jxsi}|jdxsi}|jdxsi}|jD]s\}}|j|xsi}t||dut|tr|nd|j||jddd d | |<|j!|u|r|s |j#||||||| }|jd } |jd}t|t$r|nd} t'|jdd} |jdijD]C\}}||vr d}t|j(t*r|j(j,nt/|j(dd}t|tr|r t1j2|}n||}t||j8|j:|t|j(t*r|j(j<ndt|j(t*r|j(j>nd|j@r,|j@jBr|j@jBndd | |<F t | t|| ||| | | | S#t0j4t6f$r|}YwxYw#tD$r*}|jFjId|d }Yd}~md}~wtJ$r(}|jFjMd|Yd}~d}~wwxYw)uEvaluate all feature flags for a user in a single call and return a :class:`FeatureFlagEvaluations` snapshot. Branch on ``.is_enabled()`` / ``.get_flag()`` and pass the same snapshot to :meth:`capture` via the ``flags`` option so events carry the exact flag values the code branched on. Prefer this over repeated ``get_feature_flag()`` calls and over ``capture(send_feature_flags=True)`` — it consolidates flag evaluation into a single ``/flags`` request per incoming request. Local evaluation is transparent: when the poller resolves a flag, the snapshot's ``$feature_flag_called`` events are tagged ``locally_evaluated=True`` and reason ``"Evaluated locally"``. Args: distinct_id: The user's distinct ID. If ``None``, falls back to the context distinct_id. If still unresolvable, returns an empty snapshot. groups: Mapping of group type to group key. person_properties: Person properties to use for evaluation. group_properties: Group properties keyed by group type. only_evaluate_locally: If True, never fall back to remote evaluation — flags that can't be evaluated locally are simply omitted from the snapshot. disable_geoip: Whether to disable GeoIP lookup. flag_keys: Optional list of flag keys to scope the underlying ``/flags`` request to a subset. device_id: Optional device ID override. If not provided, falls back to the context device_id (which may be set via tracing headers). Used by experience-continuity flags to match users across distinct_id changes. Returns: A :class:`FeatureFlagEvaluations` snapshot. Examples: ```python flags = posthog.evaluate_flags( "user_123", person_properties={"plan": "enterprise"}, ) if flags.is_enabled("new-dashboard"): render_new_dashboard() posthog.capture("page_viewed", distinct_id="user_123", flags=flags) ``` Category: Feature flags Nr)rrrCF)r*r+r,r-r=rAr&zEvaluated locallyT)r'rrZrr&r%r"r!rBrrrrCrrz3[FEATURE FLAGS] Unable to evaluate flags remotely: ) rrrCr*rr r r quota_limited)'"_get_feature_flag_evaluations_hostrrrr1rrqrrCr^rrDrQr2rjrbrr:intr_r$rLrgetattrjsonloadsJSONDecodeErrorr`rrZr&r%r"r#r>r~rr|r)rrr*r+r,rHrrFr!rrecordsr r rrHlocally_evaluated_keysr  local_resultfallback_to_serverr local_flagslocal_payloadsr'rlflag_defrraw_evaluated_atrr raw_payloadrs rfevaluate_flagszClient.evaluate_flags sr668  13K  -/Idmm*t2N N  7 7 "!'R &B  ,+235$( &* !& +.5#'"N"N *# ,0+S+S <5-"+ ,T, ( (04/H/H/NB"&&~6<" %))*?@FB%++-JC+//4:H/U*!+E3!7T&**3/<<%*"& GCL # & &s +.& &;> 33!&7%5"/*3'4&\\+6 #+<< #> (23CS(I$t*.LL!. sDHH,<,a@USU?VVW%XX !??9k:!FKKB"?**=+F&&rhcr|xsi}i}|r*|D]%}d||i|xsij|xsi||<'||fS)Nrl)rD)rr*r+r,all_group_propertiesrs rfrz-Client._add_local_person_and_group_propertiesy sd.3! $  &"44(.B33J?E24$Z0% !"666rh)FN)NNNNNN)NNNNNNN)NNNNNrs)r)r^Nr)qr __module__ __qualname____doc__r getLoggerr~rrrrr^r.rbrr__annotations__rqrr%DEFAULT_BUCKET_SIZEDEFAULT_REFILL_RATEDEFAULT_REFILL_INTERVAL_SECONDSr r9listrrr rr_r!rrr$rrrr#r"propertyr%setterrr r rJr3r5rMr8rNr0r:rrrr\rPrLrrhrr rnrqrr staticmethodrrrRfloatrrrrrr8rrrrrOrrrKrrrrrobjectrrIrrr'r4rrPr>rr1rXrYr3rIrCrr|rrrrhrfrrsc* '  I &C*INN,?Ad5c?GOO;<A7:uE#s(O 4<   "./*+%* % $ $PT).%)'+,0&*+/38*:*N*N*:*N*N6F6f6f$Uj/j/>)11L(M?j/JS D(Kj/X > 7$ 8D> , htn " "C "D " #$sCx. # /C /D / 1c 1d 1 2s 2t 2##     ";?6:@D(,59#'#*#*eCHo!567#*$DcN3 #* #4T#s(^(;#<= #*  ~ #* (S 2#*C=#* c5s## $#*P;?6:@D(,59#'(,(,eCHo!567(,$DcN3 (, #4T#s(^(;#<= (,  ~ (, (S 2(,C=(, c3h(,Z;?6:@D(,59#'(+(+eCHo!567(+$DcN3 (+ #4T#s(^(;#<= (+  ~ (+ (S 2(+C=(+ (+X+/:>6:@D(,59#'+0h'+0eCHo!567+0$DcN3 +0 #4T#s(^(;#<= +0  ~ +0 (S 2+0C=+0 +0^+/:>6:@D(,59#'13h'13eCHo!56713$DcN3 13 #4T#s(^(;#<= 13  ~ 13 (S 213C=13 13fZq1q1$*+>$?q1 #q1q1f$?V$LZ/1F?3/1 /1/1bZ-1!8-1Xc]-1-1^Z 0448+/(,*.:1:1:1T#s(^, :1 E(C-01 :1 uS$Y'( :1 ~:1h':1 #:1:1xZ 59"(, 1111c]11E(C-01 11 sm 11  ~ 11 #1111fNL)N,-N # N`""7r^@%EXe_%Ed%EN,2+ QM"QU<+6:@D&+)-(,#'P PP 'y1 P eCHo!567 P$DcN3P#4T#s(^(;#<=P $P#'P ~PC=P # $Pn;?6:@D&+)-(,#'3 3 3 eCHo!567 3 $DcN3 3 #4T#s(^(;#<=3  $3 #'3  ~3 C=3  # $3 t;?6:@D&+)-(,#'<P <P<P eCHo!567 <P $DcN3 <P#4T#s(^(;#<=<P $<P#'<P ~<PC=<P ) <PJ$(& &&U38_,- &  S> & sDcN23 &C=& ) &Z,0:>6:@D&+).(,#'KL KLKL i( KL eCHo!567 KL$DcN3KL#4T#s(^(;#<=KL $KL#'KL ~KLC=KL & KLj$(N NNU38_,- N  S> N sDcN23 N ~NC=N x $hsmXc]DH INT-1/ / / 9% / # / %) / U38_,-/  ~/ SM/ sm/ {+/ %SM/ p;?(,%6%6 %6 9% %6 cN %6eCHo!567%6 ~%6 %6N'S'R%. #4;?6:@D&+(,59#'-(-(eCHo!567 -( $DcN3 -( #4T#s(^(;#<= -( $-( ~-( (S 2-(C=-( $sE$),,- .-(f;?6:@D&+(,59#'NNeCHo!567 N $DcN3 N #4T#s(^(;#<= N $N ~N (S 2NC=N Nd+/G ;?6:@D&+(,)-#'G h'G eCHo!567 G $DcN3 G #4T#s(^(;#<= G  $G  ~G DI&G C=G  G RSW((3N*OV94O9$59#'<<U38_,- < (S 2<C=< % &<|Xt "' 7rhrcB|yt|tr|St|Sr)rjrb)vals rfr`r` s" {#s s8Orhr)rrrLrrr{rrrMrrrrtypingrrrr r r rBr r typing_extensionsrposthog._async_utilsr posthog.argsrrrrposthog.consumerrposthog.contextsrrrrrrrrrrrrrr rr!r"r#r#r r$rposthog.exception_capturer%posthog._loggingr&posthog.exception_utilsr'r(r)r*r+r,r-r.r/r0 posthog.feature_flag_evaluationsr1r2r3posthog.feature_flagsr4r5r6r7posthog.flag_definition_cacher8r9posthog.pollerr:posthog.requestr;r<r=r>r?r@rArBrCrDrErFrGrH posthog.typesrIrJrKrLrMrNrOrPrQrRrSrT posthog.utilsrUrVrWrXrYrZposthog.versionr[rr\r]rr.rbr_rgrmrwrrrr`rrhrfrs    22<<$;UU%$77     "    $   %T "2  C(  8D/7VD/7N^rh