File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
airbyte_cdk/sources/declarative/async_job Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 44import threading
55import uuid
66from dataclasses import dataclass , field
7- from typing import Set , Union , Mapping , Any
7+ from typing import Any , Mapping , Set , Union
88
99from airbyte_cdk .logger import lazy_log
1010from airbyte_cdk .sources .declarative .interpolation import InterpolatedString
@@ -18,10 +18,10 @@ class ConcurrentJobLimitReached(Exception):
1818
1919@dataclass
2020class JobTracker :
21- limit : Union [int , InterpolatedString ]
21+ limit : Union [int , str ]
2222 config : Mapping [str , Any ] = field (default_factory = dict )
2323
24- def __post_init__ (self ):
24+ def __post_init__ (self ) -> None :
2525 self ._jobs : Set [str ] = set ()
2626 self ._lock = threading .Lock ()
2727 if isinstance (self .limit , str ):
You can’t perform that action at this time.
0 commit comments