li$VddlmZmZmZmZddlmZmZddlm Z ddl Z Gdde Z y))OptionalUnionTupleDict)SuccessCallbackFailureCallback) EventStoreNceZdZddddddiddf deedeedeedeedeeee eeffdeede ee fd ee d ee jd dfd Zed eefd Zej$deefdZed eefdZej$deefdZed eefdZej$deefdZed eefdZej$deefdZed eeee eefffdZej$deeee eefffdZed eefdZej$deefdZed e ee ffdZej$de ee ffdZd"ded e fdZed ee fdZej$dee fdZed ee jfd Zej$dee jfd!Zy)#EmitterConfigurationN batch_size on_success on_failure byte_limitrequest_timeoutbuffer_capacitycustom_retry_codes event_storesessionreturnc ||_||_||_||_||_||_||_||_| |_y)a Configuration for the emitter that sends events to the Snowplow collector. :param batch_size: The maximum number of queued events before the buffer is flushed. Default is 10. :type batch_size: int | None :param on_success: Callback executed after every HTTP request in a flush has status code 200 Gets passed one argument, an array of dictionaries corresponding to the sent events' payloads :type on_success: function | None :param on_failure: Callback executed if at least one HTTP request in a flush has status code other than 200 Gets passed two arguments: 1) The number of events which were successfully sent 2) An array of dictionaries corresponding to the unsent events' payloads :type on_failure: function | None :param byte_limit: The size event list after reaching which queued events will be flushed :type byte_limit: int | None :param request_timeout: Timeout for the HTTP requests. Can be set either as single float value which applies to both "connect" AND "read" timeout, or as tuple with two float values which specify the "connect" and "read" timeouts separately :type request_timeout: float | tuple | None :param custom_retry_codes: Set custom retry rules for HTTP status codes received in emit responses from the Collector. By default, retry will not occur for status codes 400, 401, 403, 410 or 422. This can be overridden here. Note that 2xx codes will never retry as they are considered successful. :type custom_retry_codes: dict :param event_store: Stores the event buffer and buffer capacity. Default is an InMemoryEventStore object with buffer_capacity of 10,000 events. :type event_store: EventStore | None :param session: Persist parameters across requests by using a session object :type session: request.Session | None N) r r rrrrrrr) selfr r rrrrrrrs k/var/www/html/strategist-ai/venv_dbt/lib/python3.12/site-packages/snowplow_tracker/emitter_configuration.py__init__zEmitterConfiguration.__init__sHP%$$$.."4& c|jS)zb The maximum number of queued events before the buffer is flushed. Default is 10. ) _batch_sizers rr zEmitterConfiguration.batch_sizeK rvaluect|tr|dkr tdt|ts | td||_y)Nrzbatch_size must greater than 0zbatch_size must be of type int) isinstanceint ValueErrorrrrs rr zEmitterConfiguration.batch_sizeRA eS !eai=> >%%%*;=> > rc|jS)z Callback executed after every HTTP request in a flush has status code 200. Gets passed the number of events flushed.  _on_successrs rr zEmitterConfiguration.on_successZrrc||_yNr'r$s rr zEmitterConfiguration.on_successa  rc|jS)ac Callback executed if at least one HTTP request in a flush has status code other than 200 Gets passed two arguments: 1) The number of events which were successfully sent 2) An array of dictionaries corresponding to the unsent events' payloads  _on_failurers rrzEmitterConfiguration.on_failureesrc||_yr*r-r$s rrzEmitterConfiguration.on_failureor+rc|jS)zX The size event list after reaching which queued events will be flushed ) _byte_limitrs rrzEmitterConfiguration.byte_limitsrrct|tr|dkr tdt|ts | td||_y)Nrzbyte_limit must greater than 0zbyte_limit must be of type int)r!r"r#r1r$s rrzEmitterConfiguration.byte_limitzr%rc|jS)a3 Timeout for the HTTP requests. Can be set either as single float value which applies to both "connect" AND "read" timeout, or as tuple with two float values which specify the "connect" and "read" timeouts separately _request_timeoutrs rrz$EmitterConfiguration.request_timeouts$$$rc||_yr*r4r$s rrz$EmitterConfiguration.request_timeouts %rc|jS)z The maximum capacity of the event buffer. The default buffer capacity is 10 000 events. When the buffer is full new events are lost. )_buffer_capacityrs rrz$EmitterConfiguration.buffer_capacitys $$$rct|tr|dkr tdt|ts | td||_y)Nrz#buffer_capacity must greater than 0z#buffer_capacity must be of type int)r!r"r#r8r$s rrz$EmitterConfiguration.buffer_capacitysA eS !eaiBC C%%%*;BC C %rc|jS)zi Custom retry rules for HTTP status codes received in emit responses from the Collector. _custom_retry_codesrs rrz'EmitterConfiguration.custom_retry_codess '''rc||_yr*r;r$s rrz'EmitterConfiguration.custom_retry_codess #( r status_codect|ts tdyt|ts tdyd|cxkrdkrnn tdy||j|<||jj vS)a> Add a retry rule for HTTP status code received from emit responses from the Collector. :param status_code: HTTP response code :type status_code: int :param retry: Set the status_code to retry (True) or not retry (False). Default is True :type retry: bool zstatus_code must be of type intFzretry must be of type booli,zNcustom_retry_codes should not include codes for succesful requests (2XX codes))r!r"printboolrkeys)rr>retrys rset_retry_codez#EmitterConfiguration.set_retry_codesw+s+ 3 4%& . / + # # ` /4 ,d55::<<r[s$$0/D3}6}r