iVNHddlZddlZddlZddlZddlZddlmZmZddlmZm Z m Z m Z ddl m Z ddlmZddlmZddlmZddlmZmZmZmZdd lmZdd lmZmZmZmZm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.dd l/m0Z0m1Z1m2Z2m3Z3ddl4m5Z5m6Z6ddl7m8Z8ddl9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPddlQmRZRmSZSmTZTmUZUmVZVmWZWddlXmYZY ddlZZZn#e[$rddl\ZZYnwxYwdZ]de^e_e`ffdZadZbddZcGddedZedZfdS)N)datetime timedelta)AnyDictOptionalUnion)uuid4)tzutc) string_types)Unpack)ID_TYPES ExceptionArgOptionalCaptureArgsOptionalSetArgs)Consumer)_get_current_context,get_capture_exception_code_variables_context*get_code_variables_ignore_patterns_context(get_code_variables_mask_patterns_contextget_context_device_idget_context_distinct_idget_context_session_id new_context)ExceptionCapture)&DEFAULT_CODE_VARIABLES_IGNORE_PATTERNS$DEFAULT_CODE_VARIABLES_MASK_PATTERNSexc_info_from_errorexception_is_already_capturedexceptions_from_error_tuple handle_in_appmark_exception_as_captured#try_attach_code_variables_to_frames)InconclusiveMatchErrorRequiresServerEvaluationmatch_feature_flag_propertiesresolve_bucketing_value)FlagDefinitionCacheDataFlagDefinitionCacheProvider)Poller) DEFAULT_HOSTAPIErrorQuotaLimitErrorRequestsConnectionErrorRequestsTimeout batch_postdetermine_server_hostflagsget remote_config) FeatureFlagFeatureFlagErrorFeatureFlagResult FlagMetadataFlagsAndPayloads FlagsResponse FlagValueSendFeatureFlagsOptionsnormalize_flags_responseto_flags_and_payloads to_payloads to_values) FlagCacheRedisFlagCacheSizeLimitedDictcleanguess_timezonesystem_context)VERSIONiPreturnct|}|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 A/var/www/icac/venv/lib/python3.11/site-packages/posthog/client.pyget_identity_staterP]sdv&&K$s;''$U##(**J#E"" LL$ c|pi}t}|rO|}t||d<|||}d|vrt rt |d<|S)Nz $context_tags $session_id)r collect_tagssetkeysupdater) propertiescurrent_context context_tagss rOadd_context_tagsr[js!rJ*,,O"&3355 &),*;*;*=*=&>&> ?#J'''! J&&+A+C+C&$:$<$< =! rQcfd}|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) cDddlm}|fd}|S)Nr)wrapsc |g|Ri|S#t$r:}|jr||jdjd|cYd}~Sd}~wwxYw)Nz Error in z: ) Exceptiondebuglog exception__name__)selfargskwargsedefault_returnfuncs rOwrapperz,no_throw..decorator..wrappers &tD242226222 & & &:G""#Ct}#C#C#C#CDDD%%%%%%%  &s  A/AAA) functoolsr^)rjr^rkris` rO decoratorzno_throw..decoratorsM###### t & & & & &  &rQ)rirms` rOno_throwrozs$      rQcf eZdZdZejdZ d\d edee de edzfdZ d]dZ e dZejdZ d^dee edeedeeeeefffdZ d^dee edeedeeeffdZ d^dee edeedefdZ d_deedeedee edeedef dZededeedeefdZdefd Zedee deefd!Z!edee deefd"Z"e d`d#ed$ed%ee#ee$fd&eee%efd'eed(eedeedeefd)Z&e dad*edeefd+Z'd,ee(deefd-Z)d.Z*d/Z+d0Z,d1Z- dbd2e.d3eeddfd4Z/d5Z0d6Z1d7Z2dddddd8de3fd9Z4dddddddd:deefd;Z5deddeeee?effdIZ@ dbdeddPeefdQZAd', host='') posthog.debug = True if settings.TEST: posthog.disabled = True ``` posthogNF'Td?project_api_keyflag_definition_cache_providerin_app_modulesc! tj||_||_||_||_||_| |_|pt|_t||_ | |_ | |_ d|_ d|_d|_d|_||_||_d|_t)t*t,|_|||_d|_d|_||_||_||_||_||_ ||_!||_"d|_#||_$||_%||_&||ntN|_(||ntR|_*| |_+|' tYj-}n#t\$rd}YnwxYw||_/||_0|r8tcj2|j34tbj5n$|j34tbj6|9to|r||_8n)|j39dd|_8nd|_8|j!rtu||_#| r d|_;dS|rtyj=|j>g|_;t| D]Z}!t|j|j|j |||| | | | }"|j;A|"|r|"B[dS)a Initialize a new PostHog client instance. Args: project_api_key: The project API key. host: The host to use for the client. debug: Whether to enable debug mode. Examples: ```python from posthog import Posthog posthog = Posthog('', host='') ``` Category: Initialization Nrz/before_send is not callable, it will be ignored)hoston_errorflush_atflush_intervalgzipretriestimeouthistorical_migration)CqueueQueueapi_keyrrasend sync_moder*raw_hostr0r~rr_feature_flagsfeature_flags_by_keygroup_type_mappingcohorts poll_interval%feature_flags_request_timeout_secondspollerrB MAX_DICT_SIZErU#distinct_ids_feature_flags_reported_initialize_flag_cache flag_cacheflag_definition_version _flags_etag_flag_definition_cache_providerdisabled disable_geoiprsuper_propertiesenable_exception_autocapturelog_captured_exceptionsexception_capture privacy_modeenable_local_evaluation capture_exception_code_variablesrcode_variables_mask_patternsrcode_variables_ignore_patternsr|osgetcwdr` project_rootpersonal_api_keylogging basicConfigrbsetLevelDEBUGWARNINGcallable before_sendwarningr consumersatexitregisterjoinrangerappendstart)#rerzr~ramax_queue_sizerrrrr max_retriesrrthreadrrrrrrrrrrrrflag_fallback_cache_urlrr{rrrr|_consumers# rO__init__zClient.__init__s1j[00 '     ",  )$//   "$(!<@15 * 1 2 3B=RU3V3V0556MNN'($*./M,  *$8! 0,H)'>$!%('>$0P-,7 ) (5 ).9 + *7 + -   $!y{{  $ $ $#  $)!1  /   ! ! ! H  gm , , , , H  go . . .  " $$ (#.    !RSSS#'  #D   , <%5d%;%;D "  %!DNNN + ***DN6]] % %#JL%%#1'#)=   %%h///%NN$$$# % %sE00 E?>E?c&t|||S)a+ 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. Examples: ```python with posthog.new_context(): identify_context('') posthog.capture('event_name') ``` Category: Contexts )freshcapture_exceptionsclient)r)rerrs rOrzClient.new_contextOs#$,>t    rQc|jS)z9 Get the local evaluation feature flags. )rres rO feature_flagszClient.feature_flagses ""rQcf|pg|_d|jD|_|j JddS)z9 Set the local evaluation feature flags. cJi|] }|d|d|!Skeyr2).0flags rO z(Client.feature_flags..rs8% % % xx* K***rQNDfeature_flags_by_key should be initialized when feature_flags is set)rr)rer1s rOrzClient.feature_flagslsV $kr% % +% % % ! (44 R54444rQflag_keys_to_evaluate device_idrGc \||||||||}t|piS)a Get feature flag variants for a user by calling decide. 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_decisionr? re distinct_idgroupsperson_propertiesgroup_propertiesrrr resp_datas rOget_feature_variantszClient.get_feature_variants{sH4++      !,  ##)r)rQc \||||||||}t|piS)a Get feature flag payloads for a user by calling decide. 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)rr>rs rOget_feature_payloadszClient.get_feature_payloadssH>++      !,  9%%++rQc X||||||||}t|S)a! Get feature flags and payloads for a user by calling decide. 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)rr=) rerrrrrrrresps rOget_feature_flags_and_payloadsz%Client.get_feature_flags_and_payloadssC>&&      !'  %T***rQrrc|pi}|pi}|pi}|t}|t}||j}|si}||||||d}|r||d<t|j|jfd|ji|} t| S)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 N)rrrr geoip_disablerrr)rrrr1rr~rr<) rerrrrrrr request_datars rOrzClient.get_flags_decisions>2-3+1r  133K  -//I   .M F'!2 0*"    ! J4IL0 1 L I  >    ( 222rQeventrgc |dd}|dd}|dd}|dd}|dd}|dd}|d d} i|pit}t|}|Jt|\}} | r d |vrd|d <|||||d } |r||d <i} i} ||}|d r |ddur1|||pi|d|d| d|d} n|ddur.||||d|d| |d} ne|jr1|||pi|d|d| d|d} n-||||d|d| |d} n4#t$r'}|j d|Yd}~nd}~wwxYw| pi D] \}}|| d|<d| pi D}|r|| d<| r i| |}|| d<| | | S)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. groups: A dictionary of group information. send_feature_flags: Whether to send feature flags with 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 rNrX timestampuuidrsend_feature_flagsFrz$process_person_profile)rXrrrrz$groups should_sendonly_evaluate_locallyTrrflag_keys_filter)rrrrrr)rrrrz0[FEATURE FLAGS] Unable to get feature variants: $feature/c g|] \}}|du | S)Frn)rrvalues rO z"Client.capture..s1   eE!! !!!rQz$active_feature_flags) r2rEr[rP_parse_send_feature_flags get_all_flagsrrr`rbrcitems_enqueue)rerrgrrXrrrrr personlessmsgextra_propertiesfeature_variants flag_optionsrhfeaturevariantactive_feature_flagss rOcapturezClient.capture8sdjj55 ZZ d33 JJ{D11 zz&$''Hd++#ZZ(.>? %j11 %%%$6{$C$C!j  :3:EE49J0 1%"&     +$*Jy !+-BD556HII  &/ .  78D@@'+'9'9# & "*67J*K)56H)I&3.2.:;M.N(:(($$""9:eCC'+'@'@#*67J*K)56H)I&3.:;M.N (A(($$''+'9'9# & "*67J*K)56H)I&3.2.:;M.N(:(($$(,'@'@#*67J*K)56H)I&3.:;M.N (A(($   ""JqJJ  "2!7R > > @ @ > > GW6= 222 3 3  !1!7R > > @ @     M8L 4 5  +;,; ;J *C }}S-000sCG** H4HHcNt|trTd|d|d|d|ddSt|tr|dddddSt dt |d ) a Parse and normalize send_feature_flags parameter into a standard format. Args: send_feature_flags: Either bool or SendFeatureFlagsOptions dict Returns: SendFeatureFlagsOptions: Normalized options with keys: should_send, only_evaluate_locally, person_properties, group_properties, flag_keys_filter Raises: TypeError: If send_feature_flags is not bool or dict Trrrr)rrrrrNz%Invalid type for send_feature_flags: z. Expected bool or dict.) isinstancedictr2bool TypeErrortype)rers rOrz Client._parse_send_feature_flagss ($ / / #);)?)?+**&8%;%;>8/A#A#A  !EFFFt)DH(M(M %" ";" $2!.E493Eh3O 0"#GJ KLLOCEELGIIN#. :  + 6 "-8   38"/$3 + <""9F";;; ;55I::fd++DZZ$//F,,'%##5+  C$*9c:::J D D D H  BqBB C C C C C C C C C Ds&/H AHD:H IH<<IcX|jrdS|d}|!tjt}t |}||d<d|vr)|d}|rt||d<d|vrtt|d<|d}| dsi|d<d|dd<t|dd<||j }|r d |dd <|j ri|d|j |d<t| d d|d <t|}|jrk ||}||jd dS|}n4#t"$r'}|jd |Yd}~nd}~wwxYw|jd||js|S|jrR|jd|dt+|j|j|j|j|g|j|S |j|d|jd|d|S#t6j$r|jdYdSwxYw)z8Push a new `msg` onto the queue, return `(success, msg)`NrtzrrXzposthog-pythonz$libz $lib_versionTz$geoip_disablerz%Event dropped by before_send callbackzError in before_send callback: z queueing: %szenqueued with blocking %s.r)rrbatchrF)blockz enqueued %s.zanalytics-python queue is full)rrnowr rD isoformatpoprIr r2rFrrrCrrbrar`rcrrr/rr~rrrrputFullr)rerrrr sent_uuid modified_msgrhs rOrzClient._enqueue;s = 4 $   000I#9-- $..00K S==776??D 1*400F   &uww//CKK ww|$$ # "C $4L&!,3L.)   .M  726C . /   O N3|#4 N8M NC )#''-*F*FGGMCjj   J J#//44 'HNN#JKKK4" J J J""#HQ#H#HIIIIIIII J ~s+++y   >  HNN7W F F F   Y e%)%>        JNN3eN , , , HNN>3w< 8 8 8 z    H  = > > >44 s01F F F<F77F<=>I<<)J)(J)c|j}|j}|j|jd|dS)a Force a flush from the internal queue to the server. Do not use directly, call `shutdown()` instead. Examples: ```python posthog.capture('event_name') posthog.flush() # Ensures the event is sent immediately ``` z$successfully flushed about %s items.N)rqsizerrbra)rersizes rOflushz Client.flushsB u{}}  =tDDDDDrQc|jrC|jD];}| |,#t$rY8wxYw|jr|j|jrQ |jdS#t$r(}|j d|Yd}~dSd}~wwxYwdS)z End the consumer thread once the queue is empty. Do not use directly, call `shutdown()` instead. Examples: ```python posthog.join() ``` z/[FEATURE FLAGS] Cache provider shutdown error: N) rpauser RuntimeErrorrstoprshutdownr`rberror)rerrhs rOrz Client.joins >  N     MMOOOO#D ;  K       / V V4==????? V V VTQRTTUUUUUUUUU V V Vs'; AA3B CB;;Cc|||jr|jdSdS)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)r2rrclosers rOr7zClient.shutdownsN   ! +  " ( ( * * * * * + +rQdataold_flags_by_keyc|d|_|d|_|d|_|jrB|B||jpikr7|j}|xjdz c_|j|dSdSdSdS)zVUpdate internal flag state from cache data and invalidate evaluation cache if changed.r1rrNrx)rrrrrrinvalidate_version)rer;r< old_versions rO_update_flag_statezClient._update_flag_states"']"&';"<I  O < , T%>%D"EE6K  ( (A - ( ( O . .{ ; ; ; ; ; < <,,EErQcd}|jrQ |j}n6#t$r)}|jd|d}Yd}~nd}~wwxYw|s|jr |j}|r`|jd|||jpitj t|_ dS|j s|jdd}n6#t$r)}|jd|d}Yd}~nd}~wwxYw|r|dSdS)NTz3[FEATURE FLAGS] Cache provider should_fetch error: zA[FEATURE FLAGS] Using cached flag definitions from external cacher<r$zJ[FEATURE FLAGS] Cache empty and no flags loaded, falling back to API fetchz*[FEATURE FLAGS] Cache provider get error: )rshould_fetch_flag_definitionsr`rbr8get_flag_definitionsrar@rrr(r _last_feature_flag_pollr_fetch_feature_flags_from_api)re should_fetchrh cached_datas rO_load_feature_flagszClient._load_feature_flagss  / $ $8VVXX  $ $ $M!MM $  $ $ D $ $8MMOO,HNN[++#d6O6USU,4<<5773K3K3KD0F -,h(,  $ $ $OAOOPPP#  $  1  . . 0 0 0 0 0 1 1s3% AAA%A9D #D D7D22D7c |jpi}t|jd|jd|jd|j}|j|_|jrB|j dtj t|_ dS|j|jddS||j| |jri |j|jpg|jpi|jpid n4#t,$r'}|jd |Yd}~nd}~wwxYwni#t.$r }|jd krh|jd g|_i|_i|_|jr|j|j rt/d dn|jdkrh|jdg|_i|_i|_|jr|j|j rt/ddn|jd|Yd}~nVd}~wt,$rF}|jd|jz|j|Yd}~nd}~wwxYwtj t|_ dS)z)Fetch feature flags from the PostHog API.z*/api/feature_flag/local_evaluation/?token=z &send_cohorts )retagz;[FEATURE FLAGS] Flags not modified (304), using cached datar$NzB[FEATURE FLAGS] Unexpected empty response data in non-304 responserB)r1rrz,[FEATURE FLAGS] Cache provider store error: iz[FEATURE FLAGS] Error loading feature flags: To use feature flags, please set a valid personal_api_key. More information: https://posthog.com/docs/api/overviewzYou are using a write-only key with feature flags. To use feature flags, please set a personal_api_key More information: https://posthog.com/docs/api/overview)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.)rr2rrr~rrL not_modifiedrbrarr(r rEr;r8r@ron_flag_definitions_receivedrrrr`r+rMrclearrr)rer<responserhs rOrFz$Client._fetch_feature_flags_from_apisY 040I0OR %XT\XXX % H (}D $ Q08|uww/G/G/G,}$X  # #HMDT # U U U3 W W8UU%)%7%=2262I2OR'+|'9r!WWWHNN#URS#U#UVVVVVVVVW& T& T& Tx3v&("*,'! ?,O))+++:""!RS  {&("*,'! ?,O))+++:"" E RqRRSSS   H  r$%    H  Q          (0|uww'?'?'?$$$s[BD= !D=/#D=3DD= D8D3.D=3D88D== J#DI J#>>0DK K           rQrrrwarn_on_unknown_groupsrc L|pi}|pi}|pi}i}|ddrtd|dsdS|dpi} | d} | |jpi} | t| } | s5|jd| d|d td | |vrM|r%|jd |d d n$|jd |d d dS| |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 rz!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_cacherbucketing_value) r2r#rrKrbrrar%rrr&)re feature_flagrrrrrZrrc flag_filtersr_r group_namefocused_group_propertiesr rds rO_compute_flag_locallyzClient._compute_flag_locallys2-3+1r<>   :E B B S()QRR R)) 5#'' 228b '3'7'78V'W'W$ ' 3!%!8!>B +//4P0Q0QRRJ R  F@\FFp|~CqDFF--PQQQ''*H$$A\Z_M`AAAHNNA\Z_M`AAAu!111,LzLLL(8 'C $z*I0("&,!6!1# )    6k9O1!"&,!6!1# /    rQrrrrsend_feature_flag_eventsrrc d||||||||||  } | dSt| 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 rjN)get_feature_flagr) rerrrrrrrkrrrRs rOfeature_enabledzClient.feature_enabledsSN((  /-"7%=')     4H~~rQrc|jr<|j||}|r|jd||SdS)z?Returns a stale cached flag value if available, otherwise None.z2[FEATURE FLAGS] Using stale cached value for flag N)rget_stale_cached_flagrbinfo)rerr stale_results rO_get_stale_flag_fallbackzClient._get_stale_flag_fallback s] ? $?@@cRRL $ NNN$#trQoverride_match_valuerrrrrkrrruc |jrdS|||pi|pi|pi\}}|pi}|pi}|pi}d} d} d} d}d}| t} ||||||| }|du}|ra|p|}||||nd}t j|||} |jr$| r"|j||| |j n|r#|j |j dn | |||||| | \} } }}g}|r|tj| |tj|rd|}t j| |} |jr$| r"|j||| |j |j d|d| n#t*$rJ}|j d|tj}|||} Yd}~nZd}~wt0$rJ}|j d|tj}|||} Yd}~nd}~wt4$rI}|j d|tj}|||} Yd}~nd}~wt8$rV}|j d |tj|j}|||} Yd}~nYd}~wt>$rI}|j d |tj!}|||} Yd}~nd}~wwxYw|r>|"||| r| #nd| r| j$nd||| | || | | S) 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 -> #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_locally_evaluate_flag_compute_payload_locallyr6from_value_and_payloadrset_cached_flagrrrbr%_get_feature_flag_details_from_serverrr5ERRORS_WHILE_COMPUTING FLAG_MISSINGrfrom_flag_detailsrar, QUOTA_LIMITEDrsr.TIMEOUTr-CONNECTION_ERRORr+ api_errorrMr`rc UNKNOWN_ERROR_capture_feature_flag_called get_valuepayload)rerrrurrrrrkrr flag_result flag_details request_id evaluated_atfeature_flag_error flag_valueflag_was_locally_evaluatedlookup_match_valuererrors_while_computingerrorsrhs rO_get_feature_flag_resultzClient._get_feature_flag_results = 4  7 7 "!'R &B    ,+2-3+1r    ,0  -//I00 f&79I9  &0t%;" %K N!5!C &1--c3EFFF  ,B'K  ; //k43O#; N!)  b 4 N>>#)(%"+?O j,8N)KMM"2"IJJJ'MM"2"?@@@:),&)9)9&/A "6 ?{O33#S+t7STSTT{TT# N N N  !M!!M!MNNN%5%C"";;KMM " N N N  !Jq!J!JKKK%5%="";;KMM * N N N  !Ia!I!IJJJ%5%F"";;KMM  N N N  !Bq!B!BCCC%5%?%I%I"";;KMM  N N N""#VST#V#VWWW%5%C"";;KMM  N $   - -+6@ %%'''D'2< ##*"   sJ8CG M< ?H%% M<2?I77 M<?K M<A L&& M<3?M77M<c >||||||||||  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. rj)r) rerrrrrrrkrrs rOget_feature_flag_resultzClient.get_feature_flag_results=R,,  /-"7%='-   rQc n||||||||||  } | r| ndS)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 rjN)rr) rerrrrrrrkrrfeature_flag_results rOrmzClient.get_feature_flags[N#::  /-"7%=';   3FO",,...4OrQrrc |j|jr|d}|jr|j Jd|j|}|r |||||||}|jd|d|nm#ttf$r*} |jd|d| Yd} ~ n7d} ~ wt$r'} |j d| Yd} ~ nd} ~ wwxYw|S)Nr)rrrrz$Successfully computed flag locally: z -> zFailed to compute flag z locally: z7[FEATURE FLAGS] Error while computing variant locally: ) rrrXrr2rirbrar$r#r`rc) rerrrrrrrRrrhs rOryzClient._locally_evaluate_flags   %$*? %  # # % % %   ,88V988,0055D #99#%*;)9"+ :  HHNNRsRRRR12HIQQQHNN#OS#O#OA#O#OPPPPPPPP H&&URSUUs$;BD' C  DC;;D) match_valuerrrrrkrrrc |rtjdtd|||||||||| |  } | r| jndS)a Get the payload for a feature flag. Args: key: The feature flag key. distinct_id: The distinct ID of the user. match_value: The specific flag value to get payload for. 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: Deprecated. Use get_feature_flag() instead if you need 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 zsend_feature_flag_events is deprecated in get_feature_flag_payload() and will be removed in a future version. Use get_feature_flag() if you want to send $feature_flag_called events.) stacklevelrtN)warningswarnDeprecationWarningrr) rerrrrrrrrkrrrs rOget_feature_flag_payloadzClient.get_feature_flag_payload6sT $  Mo"     #;;  !,/-"7%='<   /BK"**tKrQc |||||||g|}|d} |d} |dd} |d} | 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. )rr requestId evaluatedAterrorsWhileComputingFlagsFr1N)rr2)rerrrrrrrrrrrr1rs rOr}z,Client._get_feature_flag_details_from_servervs++     #&%,  ]];//  }}]33 !*/JE!R!R g&&).8yuy~~~D Z7MMMrQrRrrrrrrc h|d|dnt|} |j|} | t} | |j|<| | vrd|d|d|d||i}|||d<|r||d<| r| |d <t | t rr| jr| jjr| jj|d <t | jtr6| jj r| jj |d <| jj r| jj |d <| r| |d <| d||||| | dSdS)Nrz::null::z $feature_flagz$feature_flag_responselocally_evaluatedrz$feature_flag_payloadz$feature_flag_request_idz$feature_flag_evaluated_atz$feature_flag_reasonz$feature_flag_versionz$feature_flag_idz$feature_flag_errorz$feature_flag_called)rrXrr)rKrr2rUrr4reason descriptionmetadatar7versionidradd)rerrrRrrrrrrrrfeature_flag_reported_keyreported_flagsrXs rOrz#Client._capture_feature_flag_calleds H H8#3ZZX H H "AEEkRR  ! UUNDRD 4[ A $N : :((#%?!C!!8 *J"6= 23 D9C 56 H;G 78, 44 R&Y<+>+JY9E9L9XJ56l3\BBR#,4(19##:;$,/R9E9N9Q #56! G4F 01 LL&'%+       8 9 9 9 9 9I ; :rQc|jrdS|j|jddS t |j|j|j||jS#t$r(}|j d|Yd}~dSd}~wwxYw)Nz`[FEATURE FLAGS] You have to specify a personal_api_key to fetch decrypted feature flag payloads.)rz>[FEATURE FLAGS] Unable to get decrypted feature flag payload: ) rrrbrr3rr~rr`rc)rerrhs rOget_remote_config_payloadz Client.get_remote_config_payloads = 4  ( H  r   4  %  B      H  TQRTT          s'A B BBc,d}|j|S|j|}|rl|dpi}|dpi}t|tr|rdnt |}||d}|S)Nr^payloadstrue)rr2rrrK)rerrrflag_definitionrf flag_payloads lookup_values rOrzzClient._compute_payload_locallys  $ ,N377<<  <*..y99?RL(,,Z88>BM k400&5@&%%  $'' d;;GrQrrrrrrrc L|||||||||} | 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) rerrrrrrrrrRs rOrzClient.get_all_flagssDD22 /-"7'"73   ''rQc x|jrdddS|||||\}}|t}|||||||\} } | rb|s` ||||||||} t | S#t $r'} |jd| Yd} ~ nd} ~ wwxYw| S)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 NrfeatureFlagPayloads)rrrrr)rrrrrrz:[FEATURE FLAGS] Unable to get feature flags and payloads: ) rrxr#_get_all_flags_and_payloads_locallyrr=r`rbrc) rerrrrrrrrrRfallback_to_flagsdecide_responserhs rOrz!Client.get_all_flags_and_payloads-sJD = G$(FF F  7 7V%68H   ,+  -//I&*&N&N /-"7 'O' ' ##  %:  "&"9"9!&7%5"/*?'#:##-_===   ""TQRTT  s*B B7B22B7)rrrZrrc "|pi}|pi}|j|jr|i}i} d} |jr|j} |r"t|fd|jD} | D]} || |||||||| d<|| d|| d} | | | | d<^#t $rd} Ylt$r)}|j d|d} Yd}~d}~wwxYwnd} || d| fS)NFc(g|]}|dv |Srrn)rr flag_keys_sets rOrz>Client._get_all_flags_and_payloads_locally..s.$$$!4;-;W;WD;W;W;WrQrYrTz;[FEATURE FLAGS] Error while computing variant and payload: r) rrrXrUrirzr#r`rbrc)rerrrrrZrrr1rrflags_to_processrmatched_payloadrhrs @rOrz*Client._get_all_flags_and_payloads_locallyxs.3+1r   %$*? %  # # % % %&(#%!  " %#1 $  #$9 : : $$$$%)%7$$$ ) - --)-)C)C#%*;)9/E"+*D**E$u+&'+&C&CU U4;%7''O'20?e-----(,%%% ---H&&YVWYY)-%%%%%% -' -2!% "#+    s)AC D DC??Dc|sdS ddlm}m}n#t$r ddlm}m}YnwxYw ||}|j}||j}t|ddgd}|dkr:t|ddgd}t||S|d kr ddl } |jd } |j s|j r| |j pd d |j pd d z } | |j pdd |jpdz } |jr | |jz } | | } | t%| |S#t$r|jdYdSt*$r)} |jd| dYd} ~ dSd} ~ wwxYwt-d|d#t*$r+} |jd|d| Yd} ~ dSd} ~ wwxYw)a9Initialize feature flag cache for graceful degradation during service outages. When enabled, the cache stores flag evaluation results and serves them as fallback when the PostHog API is unavailable. This ensures your application continues to receive flag values even during outages. Args: cache_url: Cache configuration URL. Examples: - None: Disable caching - "memory://local/?ttl=300&size=10000": Memory cache with TTL and size - "redis://localhost:6379/0/?ttl=300": Redis cache with TTL - "redis://username:password@host:port/?ttl=300": Redis with auth Example usage: # Memory cache client = Client( "your-api-key", flag_fallback_cache_url="memory://local/?ttl=300&size=10000" ) # Redis cache client = Client( "your-api-key", flag_fallback_cache_url="redis://localhost:6379/0/?ttl=300" ) # Normal evaluation - cache is populated flag_value = client.get_feature_flag("my-flag", "user123") # During API outage - returns cached value instead of None flag_value = client.get_feature_flag("my-flag", "user123") # Uses cache Nr)parse_qsurlparsettli,memoryr1rsredisz://:@ localhosti) default_ttlz:[FEATURE FLAGS] Redis not available, flag caching disabledz)[FEATURE FLAGS] Redis connection failed: z, flag caching disabledzUnknown cache URL scheme: z". Supported schemes: memory, redisz+[FEATURE FLAGS] Failed to parse cache URL 'z': ) urllib.parserr ImportErrorschemelowerqueryintr2r@rusernamepasswordhostnameportpathfrom_urlpingrArbrr` ValueError) re cache_urlrrparsedr query_paramsrr1r redis_urlrrhs rOrzClient._initialize_flag_cachesB 4 4 7 7 7 7 7 7 7 7 7 4 4 4 3 3 3 3 3 3 3 3 3 3 42 Xi((F]((**F#8FL11Ll&&use44Q788C!!<++FUG< G F>F93G9F>>G H  HH c|jSN)rrs rOfeature_flag_definitionszClient.feature_flag_definitions s !!rQcxd|i|pi}i}|r+|D](}d||i|pi|pi||<)||fS)Nrr r)rerrrrall_person_propertiesall_group_propertiesrgs rOrxz-Client._add_local_person_and_group_properties s ;!  &B!  "  $    &"44(.B33J??E24$Z00 %&:::rQ)NFrsTNrtruFrvFrwrxryNFTFrvNFFNFNNTNFNNN)FT)NNNNNN)NNNNNNN)NNNNNrr)Jrd __module__ __qualname____doc__r getLoggerrbrKrr(listrrpropertyrsetterrrrrrr8rr r9rror rrr;rrrUrrrrrrrr"rr2rr7r'r@rIrFrXr:rirnr6rsrrrmryrtupler4rr}rrrzrrrrrrxrnrQrOrqrqs  ' I & &C   "./%* % $ $PT).%)'++/Cd%d%d%:)11L(M;d%BS D(Cd%d%d%d%L    ,##X#      "59#'#*#* (S 2#*C=#* c5s## $#*#*#*#*P59#'(,(, (S 2(,C=(, c3h(,(,(,(,Z59#'(+(+ (S 2(+C=(+ (+(+(+(+X+/!%59#'B3B3h'B3B3 (S 2B3C=B3 B3B3B3B3HXZZT1T1$*+>$?T1 #T1T1T1ZT1l$?V$$$$LXZZ-1F?3-1 -1-1-1Z-1^XZZ+1!8+1Xc]+1+1+1Z+1ZXZZ 0448"(,*.81818181T#s(^, 81 E(C-01 81 sm 81 ~81h'81 #818181Z81tXZZ   /1/1/1c]/1/1/1Z/1byDL)yD,-yDyDyDyDvPPPdEEE VVV8 + + + QU<<+ & sCx. &C=& ) &&&&Z,0#!&#'>L>L>L i( >LC=>L>L>L>LP$(NN NNS#X N  S> N sCx. N ~NC=N x $hsmXc]DH INNNNT-1;:;:;:;:9% ;: # ;: %) ;:S#X;: ~;:SM;:sm;:{+;:%SM;:;:;:;:zS.%. #4#59#'-(-(-( (S 2-(C=-( $sE$),,- .-(-(-(-(f#59#'III (S 2IC=I IIII`$59#'<<<<S%S/)* < (S 2<C=< % &<<<<|[[[z""";;;;;rQrqcV|dSt|tr|St|Sr)rr rK)vals rOrIrI) s. {t#|$$ s88OrQr)grrrrrrrtypingrrrrrr dateutil.tzr sixr typing_extensionsr posthog.argsr rrrposthog.consumerrposthog.contextsrrrrrrrrposthog.exception_capturerposthog.exception_utilsrrrrrr r!r"posthog.feature_flagsr#r$r%r&posthog.flag_definition_cacher'r(posthog.pollerr)posthog.requestr*r+r,r-r.r/r0r1r2r3 posthog.typesr4r5r6r7r8r9r:r;r<r=r>r? posthog.utilsr@rArBrCrDrEposthog.versionrFrrrrrrKrrPr[roobjectrqrIrnrQrOrs  ((((((((------------$$$$$$UUUUUUUUUUUU%%%%%%                    766666                     "!!!!!                                                    $#####LLLL   %T "2         8P";P";P";P";P";VP";P";P";fDs&C++ C76C7