|
4 | 4 | import typing
|
5 | 5 | from typing import List
|
6 | 6 | from typing import Optional
|
7 |
| -from typing import Union |
8 | 7 |
|
9 | 8 | import attr
|
10 | 9 |
|
@@ -134,7 +133,9 @@ class _ProfilerInstance(service.Service):
|
134 | 133 | _recorder = attr.ib(init=False, default=None)
|
135 | 134 | _collectors = attr.ib(init=False, default=None)
|
136 | 135 | _scheduler = attr.ib(
|
137 |
| - init=False, default=None, type=Union[scheduler.Scheduler, serverless_scheduler.ServerlessScheduler] |
| 136 | + init=False, |
| 137 | + default=None, |
| 138 | + type=scheduler.Scheduler, |
138 | 139 | )
|
139 | 140 | _lambda_function_name = attr.ib(
|
140 | 141 | init=False, factory=lambda: os.environ.get("AWS_LAMBDA_FUNCTION_NAME"), type=Optional[str]
|
@@ -219,12 +220,10 @@ def __attrs_post_init__(self):
|
219 | 220 | exporters = self._build_default_exporters()
|
220 | 221 |
|
221 | 222 | if exporters:
|
222 |
| - if self._lambda_function_name: |
223 |
| - scheduler_class = ( |
224 |
| - serverless_scheduler.ServerlessScheduler |
225 |
| - ) # type: Union[type[scheduler.Scheduler], type[serverless_scheduler.ServerlessScheduler]] |
226 |
| - else: |
| 223 | + if not self._lambda_function_name: |
227 | 224 | scheduler_class = scheduler.Scheduler
|
| 225 | + else: |
| 226 | + scheduler_class = serverless_scheduler.ServerlessScheduler |
228 | 227 | self._scheduler = scheduler_class(recorder=r, exporters=exporters, before_flush=self._collectors_snapshot)
|
229 | 228 |
|
230 | 229 | self.set_asyncio_event_loop_policy()
|
|
0 commit comments