Implement SLASensor (#177)

* init sla sensor * SLASensor implementation * feat: monitor any active workflow; refactor notification * test SLASensor * include SLASensor * update docs * feat: sla in tag * SLASensor docs * update docstring Signed-off-by: Michael Espiritu <[email protected]> * type check email_params * email params config * SLASensor: recipient lists, priority * SLASensor examples * update contributors --------- Signed-off-by: Michael Espiritu <[email protected]>
Nike-Inc · Nov 22, 2024 · 51f44eb · 51f44eb
1 parent 5230b09
commit 51f44eb
Show file tree

Hide file tree

Showing 6 changed files with 883 additions and 0 deletions.
diff --git a/CONTRIBUTORS.md b/CONTRIBUTORS.md
@@ -17,6 +17,7 @@ Thanks to the contributors who helped on this project apart from the authors
 * [Madhusudan Koukutla](https://www.linkedin.com/in/madhusudan-reddy/)
 * [Surya Teja Jagatha](https://www.linkedin.com/in/surya-teja-jagatha/)
 * [Iris Meerman](https://www.linkedin.com/in/iris-meerman-92694675/)
+* [Michael Espiritu](https://www.linkedin.com/in/michaelespiritu92/)
 
 # Honorary Mentions
 Thanks to the team below for invaluable insights and support throughout the initial release of this project

diff --git a/brickflow_plugins/__init__.py b/brickflow_plugins/__init__.py
@@ -44,6 +44,7 @@ def setup_logger():
     VolumesToBoxOperator,
     BoxOperator,
 )
+from brickflow_plugins.databricks.sla_sensor import SLASensor
 
 
 def load_plugins(cache_bust: Optional[pluggy.PluginManager] = None) -> None:
@@ -83,6 +84,7 @@ def ensure_installation():
     "BoxToVolumesOperator",
     "VolumesToBoxOperator",
     "BoxOperator",
+    "SLASensor",
     "load_plugins",
     "ensure_installation",
 ]