Skip to content

Commit dbd3e3c

Browse files
committed
Remove processor.py
1 parent 14a44e0 commit dbd3e3c

File tree

1 file changed

+12
-2
lines changed
  • sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_quickpulse

1 file changed

+12
-2
lines changed

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_quickpulse/_processor.py

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,22 @@
99

1010
# pylint: disable=protected-access
1111
class _QuickpulseLogRecordProcessor(LogRecordProcessor):
12+
def __init__(self):
13+
super().__init__()
14+
self.call_on_emit = hasattr(super(), 'on_emit')
1215

13-
def emit(self, log_data: LogData) -> None: # type: ignore
16+
def on_emit(self, log_data: LogData) -> None: # type: ignore
1417
qpm = _QuickpulseManager._instance
1518
if qpm:
1619
qpm._record_log_record(log_data)
17-
super().emit(log_data) # type: ignore[safe-super]
20+
if self.call_on_emit:
21+
super().on_emit(log_data) # type: ignore[safe-super]
22+
else:
23+
# this method was removed in opentelemetry-sdk and replaced with on_emit
24+
super().emit(log_data) # type: ignore[safe-super,misc] # pylint: disable=no-member
25+
26+
def emit(self, log_data: LogData) -> None:
27+
self.on_emit(log_data)
1828

1929
def shutdown(self):
2030
pass

0 commit comments

Comments
 (0)