:py:mod:`astronomer.providers.snowflake.hooks.snowflake`
========================================================

.. py:module:: astronomer.providers.snowflake.hooks.snowflake


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.snowflake.hooks.snowflake.SnowflakeHookAsync



Functions
~~~~~~~~~

.. autoapisummary::

   astronomer.providers.snowflake.hooks.snowflake.fetch_all_snowflake_handler
   astronomer.providers.snowflake.hooks.snowflake.fetch_one_snowflake_handler



.. py:function:: fetch_all_snowflake_handler(cursor)

   Handler for SnowflakeCursor to return results


.. py:function:: fetch_one_snowflake_handler(cursor)

   Handler for SnowflakeCursor to return results


.. py:class:: SnowflakeHookAsync(*args, **kwargs)

   Bases: :py:obj:`airflow.providers.snowflake.hooks.snowflake.SnowflakeHook`

   A client to interact with Snowflake.

   This hook requires the snowflake_conn_id connection. The snowflake host, login,
   and, password field must be setup in the connection. Other inputs can be defined
   in the connection or hook instantiation. If used with the S3ToSnowflakeOperator
   add 'aws_access_key_id' and 'aws_secret_access_key' to extra field in the connection.

   :param snowflake_conn_id: Reference to
       :ref:`Snowflake connection id<howto/connection:snowflake>`
   :param account: snowflake account name
   :param authenticator: authenticator for Snowflake.
       'snowflake' (default) to use the internal Snowflake authenticator
       'externalbrowser' to authenticate using your web browser and
       Okta, ADFS or any other SAML 2.0-compliant identify provider
       (IdP) that has been defined for your account
       'https://<your_okta_account_name>.okta.com' to authenticate
       through native Okta.
   :param warehouse: name of snowflake warehouse
   :param database: name of snowflake database
   :param region: name of snowflake region
   :param role: name of snowflake role
   :param schema: name of snowflake schema
   :param session_parameters: You can set session-level parameters at
       the time you connect to Snowflake

   .. py:method:: run(sql, autocommit = True, parameters = None)

      Runs a SQL command or a list of SQL commands.

      :param sql: the sql string to be executed with possibly multiple statements,
        or a list of sql statements to execute
      :param autocommit: What to set the connection's autocommit setting to before executing the query.
      :param parameters: The parameters to render the SQL query with.


   .. py:method:: check_query_output(query_ids, handler = None, return_last = True)

      Once the query is finished fetch the result and log it in airflow


   .. py:method:: get_query_status(query_ids, poll_interval)
      :async:

      Get the Query status by query ids.