_mysql_extraction_strategy()

Class: JobsAustriaCacheProcessRework
File: jobs_austria_cache_key_sync.py · line 27

Internal strategy to fetch data using a connection from the pool.

Signature

Parameters	query: str
Returns	not annotated
Async	No
Visibility	Private

Implementation

def _mysql_extraction_strategy(self, query: str) -> pd.DataFrame:
    """Internal strategy to fetch data using a connection from the pool."""
    with self.engine.connect() as connection:
        return pd.read_sql(query, connection)