blob: 076298c6ea129bb025ffff286743492e6a74ddad [file] [log] [blame]
:mod:`airflow.providers.salesforce.operators.tableau_refresh_workbook`
======================================================================
.. py:module:: airflow.providers.salesforce.operators.tableau_refresh_workbook
Module Contents
---------------
.. py:class:: TableauRefreshWorkbookOperator(*, workbook_name: str, site_id: Optional[str] = None, blocking: bool = True, tableau_conn_id: str = 'tableau_default', **kwargs)
Bases: :class:`airflow.models.BaseOperator`
Refreshes a Tableau Workbook/Extract
.. seealso:: https://tableau.github.io/server-client-python/docs/api-ref#workbooks
:param workbook_name: The name of the workbook to refresh.
:type workbook_name: str
:param site_id: The id of the site where the workbook belongs to.
:type site_id: Optional[str]
:param blocking: By default the extract refresh will be blocking means it will wait until it has finished.
:type blocking: bool
:param tableau_conn_id: The Tableau Connection id containing the credentials
to authenticate to the Tableau Server.
:type tableau_conn_id: str
.. method:: execute(self, context: dict)
Executes the Tableau Extract Refresh and pushes the job id to xcom.
:param context: The task context during execution.
:type context: dict
:return: the id of the job that executes the extract refresh
:rtype: str
.. method:: _get_workbook_by_name(self, tableau_hook: TableauHook)
.. method:: _refresh_workbook(self, tableau_hook: TableauHook, workbook_id: str)