o i.@sdZddlmZddlmZddlmZmZmZm Z m Z m Z m Z ddl mZddlZGdddZed d Gd d d Zed d Gd ddZed d GdddZed d GdddZed d GdddZGdddeZdS)zlTelemetry for SDK Core. (unstable) Nothing in this module should be considered stable. The API may change. ) annotations) dataclass)AnyCallableDictMappingOptionalSequenceType)ProtocolNc@sFeZdZdZeddd Zdd dZdddZdddZdddZ dS)RuntimezRuntime for SDK Core. thread_idintexc_typeType[BaseException]returnboolcCstjj||S)z3Internal helper for raising an exception in thread.) temporaliobridgetemporal_sdk_bridgeraise_in_thread)r rr_/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/temporalio/bridge/runtime.py_raise_in_threadszRuntime._raise_in_thread telemetryTelemetryConfigNonecCstjj||_dS)zCreate SDK Core runtime.N)rrr init_runtime_ref)selfrrrr__init__szRuntime.__init__durations_as_seconds Sequence[Any]cCs |j|S)zGet buffered metrics.)rretrieve_buffered_metrics)rr!rrrr#s z!Runtime.retrieve_buffered_metricsmessagestr extra_datacC|j||dS)z$Write a test core log at INFO level.N)rwrite_test_info_logrr$r&rrrr("zRuntime.write_test_info_logcCr')z%Write a test core log at DEBUG level.N)rwrite_test_debug_logr)rrrr+&r*zRuntime.write_test_debug_logN)r rrrrr)rrrr)r!rrr")r$r%r&r%rr) __name__ __module__ __qualname____doc__ staticmethodrr r#r(r+rrrrr s    r T)frozenc@"eZdZUdZded<ded<dS) LoggingConfigzeZdZUdZded<ded<ded<ded<dZd ed <dS) PrometheusConfigz?Python representation of the Rust struct for Prometheus config.r% bind_addressrcounters_total_suffix unit_suffixr!Nz'Optional[Mapping[str, Sequence[float]]]histogram_bucket_overrides)r,r-r.r/r7rKrrrrrGKs rGc@r2)rz>Python representation of the Rust struct for telemetry config.zOptional[LoggingConfig]loggingzOptional[MetricsConfig]metricsNr6rrrrrVr8rc@sVeZdZdZedddZedddZedd d Zedd d ZedddZ dS)BufferedLogEntryzA buffered log entry.rr%cCdS)z"Target category for the log entry.NrrrrrtargetbzBufferedLogEntry.targetcCrO)z Log message.NrrPrrrr$grRzBufferedLogEntry.messagefloatcCrO)z,Time as from ``time.time`` since Unix epoch.NrrPrrrtimelrRzBufferedLogEntry.timercCrO)z"Python log level, with trace as 9.NrrPrrrlevelqrRzBufferedLogEntry.levelDict[str, Any]cCrO)aAdditional log entry fields. Requesting this property performs a conversion from the internal representation to the Python representation on every request. Therefore callers should store the result instead of repeatedly calling. Raises: Exception: If the internal representation cannot be converted. This should not happen and if it does it is considered a bug in the SDK and should be reported. NrrPrrrfieldsvs zBufferedLogEntry.fieldsN)rr%)rrS)rr)rrV) r,r-r.r/propertyrQr$rTrUrWrrrrrN_s    rN)r/ __future__r dataclassesrtypingrrrrrr r typing_extensionsr %temporalio.bridge.temporal_sdk_bridgerr r3r9rArGrrNrrrrs$  $