:py:mod:`astronomer.providers.snowflake.triggers.snowflake_trigger`
===================================================================

.. py:module:: astronomer.providers.snowflake.triggers.snowflake_trigger


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.snowflake.triggers.snowflake_trigger.SnowflakeTrigger



Functions
~~~~~~~~~

.. autoapisummary::

   astronomer.providers.snowflake.triggers.snowflake_trigger.get_db_hook



.. py:function:: get_db_hook(snowflake_conn_id)

   Create and return SnowflakeHookAsync.
   :return: a SnowflakeHookAsync instance.


.. py:class:: SnowflakeTrigger(task_id, polling_period_seconds, query_ids, snowflake_conn_id)

   Bases: :py:obj:`airflow.triggers.base.BaseTrigger`

   Snowflake Trigger inherits from the BaseTrigger,it is fired as
   deferred class with params to run the task in trigger worker and
   fetch the status for the query ids passed

   :param task_id: Reference to task id of the Dag
   :param polling_period_seconds:  polling period in seconds to check for the status
   :param query_ids: List of Query ids to run and poll for the status
   :param snowflake_conn_id: Reference to Snowflake connection id

   .. py:method:: serialize(self)

      Serializes SnowflakeTrigger arguments and classpath.


   .. py:method:: run(self)
      :async:

      Makes a series of connections to snowflake to get the status of the query
      by async get_query_status function