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

from snowflake_connector.etl_connector import SQLLoader

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


class GfKStreamingSFExecutor(base_executor.SnowflakeSQLExecutorSR):
    """SnowflakeSQLExecutor for gfk_streaming 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