:py:mod:`databricks.operators.databricks`
=========================================

.. py:module:: databricks.operators.databricks


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

Classes
~~~~~~~

.. autoapisummary::

   databricks.operators.databricks.DatabricksSubmitRunOperatorAsync
   databricks.operators.databricks.DatabricksRunNowOperatorAsync




.. py:class:: DatabricksSubmitRunOperatorAsync

   Bases: :py:obj:`airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator`

   .. py:method:: execute(self, context)

      Execute the Databricks trigger, and defer execution as expected. It makes two non-async API calls to
      submit the run, and retrieve the run page URL. It also pushes these
      values as xcom data if do_xcom_push is set to True in the context.


   .. py:method:: execute_complete(self, context, event = None)

      Callback for when the trigger fires - returns immediately.
      Relies on trigger to throw an exception, otherwise it assumes execution was
      successful.



.. py:class:: DatabricksRunNowOperatorAsync

   Bases: :py:obj:`airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator`

   .. py:method:: execute(self, context)

      Logic that the operator uses to execute the Databricks trigger,
      and defer execution as expected. It makes two non-async API calls to
      submit the run, and retrieve the run page URL. It also pushes these
      values as xcom data if do_xcom_push is set to True in the context.


   .. py:method:: execute_complete(self, context, event = None)

      Callback for when the trigger fires - returns immediately.
      Relies on trigger to throw an exception, otherwise it assumes execution was
      successful.