fix import

Author: berndverst

durabletask-azuremanaged/durabletask/azuremanaged/worker.py

@@ -35,7 +35,7 @@ class DurableTaskSchedulerWorker(TaskHubGrpcWorker):
     Example:
         >>> from azure.identity import DefaultAzureCredential
         >>> from durabletask.azuremanaged import DurableTaskSchedulerWorker
-        >>> from durabletask import ConcurrencyOptions
+        >>> from durabletask.worker import ConcurrencyOptions
         >>> 
         >>> credential = DefaultAzureCredential()
         >>> concurrency = ConcurrencyOptions(max_concurrent_activities=10)

tests/durabletask/test_concurrency_options.py

@@ -3,8 +3,7 @@
 
 import os
 
-from durabletask import ConcurrencyOptions
-from durabletask.worker import TaskHubGrpcWorker
+from durabletask.worker import ConcurrencyOptions, TaskHubGrpcWorker
 
 
 def test_default_concurrency_options():

tests/durabletask/test_worker_concurrency_loop.py

@@ -2,8 +2,7 @@
 import threading
 import time
 
-from durabletask import ConcurrencyOptions
-from durabletask.worker import TaskHubGrpcWorker
+from durabletask.worker import ConcurrencyOptions, TaskHubGrpcWorker
 
 
 class DummyStub:

tests/durabletask/test_worker_concurrency_loop_async.py

@@ -1,7 +1,6 @@
 import asyncio
 
-from durabletask import ConcurrencyOptions
-from durabletask.worker import TaskHubGrpcWorker
+from durabletask.worker import ConcurrencyOptions, TaskHubGrpcWorker
 
 
 class DummyStub: