"""Snowflake executor for GfK Physical Ingestion Workflow."""

from snowflake_connector.etl_connector import SQLLoader

from feed_ingestion.common.staging_raw_sf import base_executor
from feed_ingestion.flows.gfk_physical import config


class GfKPhysicalSFExecutor(base_executor.SnowflakeSQLExecutorSR):
    """SnowflakeSQLExecutor for gfk_physical flow."""

    sql_loader = SQLLoader(__file__)

    @property
    def feed_name(self):
        """Name of the feed."""
        return config.feed_name

    @property
    def staging_raw_table(self):
        """Name of the staging_raw table."""
        return config.staging_raw_table