__init__()

Class: JobsAustriaETLCache
File: jobs_austria_cache_import.py · line 37

Signature

Parameters	apify_input_config_path: str, insert_strategy: Callable
Returns	not annotated
Async	No
Visibility	Public

Implementation

def __init__(self, apify_input_config_path: str, insert_strategy: Callable):
    self.queue = asyncio.Queue()
    self.insert_strategy = insert_strategy
    self.apify_actor_loader = ApifyActorLoader(apify_input_config_path)
    self.generators = None  # deferred until run()
    self.mysql_loader = None  # deferred until connect()
    self.engine = None
    self.connection = None