TableauRefreshABCOperator, TableauRefreshDataSourceOperator and Table…

…auRefreshWorkBookOperator (#91) * Initial implementation of TableauWrapper and Airflow operators * docs / todos / restyle docstrings * update docs; examples validate * add unit tests for TableauWrapper * limit upper pytest version due to changes in test behaviour * add watchdog dev dependency * update lock file --------- Co-authored-by: Maxim Mityutko <[email protected]> Co-authored-by: Maxim Mityutko <[email protected]>
Nike-Inc · Mar 2, 2024 · 6ba515b · 6ba515b
1 parent 336d1c9
commit 6ba515b
Show file tree

Hide file tree

Showing 11 changed files with 2,037 additions and 923 deletions.
diff --git a/brickflow_plugins/__init__.py b/brickflow_plugins/__init__.py
@@ -22,6 +22,10 @@ def setup_logger():
  AutosysSensor,
  AirflowProxyOktaClusterAuth,
 )
+from brickflow_plugins.airflow.operators.external_tasks_tableau import (
+ TableauRefreshDataSourceOperator,
+ TableauRefreshWorkBookOperator,
+)
 from brickflow_plugins.airflow.operators.native_operators import (
  BashOperator,
  BranchPythonOperator,
@@ -67,6 +71,8 @@ def ensure_installation():
  "WorkflowDependencySensor",
  "SnowflakeOperator",
  "UcToSnowflakeOperator",
+ "TableauRefreshDataSourceOperator",
+ "TableauRefreshWorkBookOperator",
  "load_plugins",
  "ensure_installation",
 ]
diff --git a/brickflow_plugins/airflow/operators/__init__.py b/brickflow_plugins/airflow/operators/__init__.py
@@ -117,6 +117,8 @@ class CatchAllOperatorModifier(OperatorModifier):
  "ShortCircuitOperator",
  "TaskDependencySensor",
  "AutosysSensor",
+ "TableauRefreshDataSourceOperator",
+ "TableauRefreshWorkBookOperator",
  ]
 
  def _validate_operators(self, operator: BaseOperator, task: Task) -> None: