Skip to content

Commit 7f44a0d

Browse files
committed
Type-hint log_handler
1 parent 1240236 commit 7f44a0d

File tree

3 files changed

+6
-4
lines changed

3 files changed

+6
-4
lines changed

durabletask-azuremanaged/durabletask/azuremanaged/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ def __init__(self, *,
2121
token_credential: Optional[TokenCredential],
2222
secure_channel: bool = True,
2323
default_version: Optional[str] = None,
24-
log_handler=None,
24+
log_handler: Optional[logging.Handler] = None,
2525
log_formatter: Optional[logging.Formatter] = None):
2626

2727
if not taskhub:

durabletask-azuremanaged/durabletask/azuremanaged/worker.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,8 @@ class DurableTaskSchedulerWorker(TaskHubGrpcWorker):
3030
concurrency_options (Optional[ConcurrencyOptions], optional): Configuration
3131
for controlling worker concurrency limits. If None, default concurrency
3232
settings will be used.
33+
log_handler (Optional[logging.Handler], optional): Custom logging handler for worker logs.
34+
log_formatter (Optional[logging.Formatter], optional): Custom log formatter for worker logs.
3335
3436
Raises:
3537
ValueError: If taskhub is empty or None.
@@ -61,7 +63,7 @@ def __init__(self, *,
6163
token_credential: Optional[TokenCredential],
6264
secure_channel: bool = True,
6365
concurrency_options: Optional[ConcurrencyOptions] = None,
64-
log_handler=None,
66+
log_handler: Optional[logging.Handler] = None,
6567
log_formatter: Optional[logging.Formatter] = None):
6668

6769
if not taskhub:

durabletask/worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -246,7 +246,7 @@ class TaskHubGrpcWorker:
246246
Defaults to the value from environment variables or localhost.
247247
metadata (Optional[list[tuple[str, str]]], optional): gRPC metadata to include with
248248
requests. Used for authentication and routing. Defaults to None.
249-
log_handler (optional): Custom logging handler for worker logs. Defaults to None.
249+
log_handler (optional[logging.Handler]): Custom logging handler for worker logs. Defaults to None.
250250
log_formatter (Optional[logging.Formatter], optional): Custom log formatter.
251251
Defaults to None.
252252
secure_channel (bool, optional): Whether to use a secure gRPC channel (TLS).
@@ -314,7 +314,7 @@ def __init__(
314314
*,
315315
host_address: Optional[str] = None,
316316
metadata: Optional[list[tuple[str, str]]] = None,
317-
log_handler=None,
317+
log_handler: Optional[logging.Handler] = None,
318318
log_formatter: Optional[logging.Formatter] = None,
319319
secure_channel: bool = False,
320320
interceptors: Optional[Sequence[shared.ClientInterceptor]] = None,

0 commit comments

Comments
 (0)