Skip to content

Commit 93c9317

Browse files
committed
add return types and fix list typing
1 parent 7d1b086 commit 93c9317

File tree

1 file changed

+4
-4
lines changed
  • ddtrace/contrib/internal/azure_eventhubs

1 file changed

+4
-4
lines changed

ddtrace/contrib/internal/azure_eventhubs/utils.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ def create_context(
2424
pin: Pin,
2525
operation_name: str,
2626
resource: Optional[str] = None,
27-
):
27+
) -> core.ExecutionContext:
2828
return core.context_with_data(
2929
context_name,
3030
span_name=operation_name,
@@ -38,7 +38,7 @@ def create_context(
3838
def handle_event_hubs_event_data_context(
3939
span: Span,
4040
event_data_arg_value: Union[
41-
EventData, AmqpAnnotatedMessage, List[EventData], List[AmqpAnnotatedMessage], EventDataBatch
41+
EventData, AmqpAnnotatedMessage, List[Union[EventData, AmqpAnnotatedMessage]], EventDataBatch
4242
],
4343
):
4444
if isinstance(event_data_arg_value, (EventData, AmqpAnnotatedMessage)):
@@ -94,9 +94,9 @@ def inject_context(span: Span, event_data: Union[EventData, AmqpAnnotatedMessage
9494

9595
def handle_event_data_attributes(
9696
event_data_arg_value: Union[
97-
EventData, AmqpAnnotatedMessage, List[EventData], List[AmqpAnnotatedMessage], EventDataBatch
97+
EventData, AmqpAnnotatedMessage, List[Union[EventData, AmqpAnnotatedMessage]], EventDataBatch
9898
],
99-
):
99+
) -> tuple[Union[str, None], Union[str, None]]:
100100
if isinstance(event_data_arg_value, EventData):
101101
batch_count = None
102102
message_id = event_data_arg_value.message_id

0 commit comments

Comments
 (0)