alerting for ETA (#5579)

* alerting and stuff * . * . * cleaner * missing variable * cleanup * tests * alerting * uncomment * Update public/pathway/python/pathway/tests/test_deduplicate.py * Update projects/pathway/realtime/main.py * cleaner * . * LOCAL_RUN * rename * debug * flake8 * rename schema * ret schema * schemas * cleanup * . * OpenTelemetry init (#5426) --------- Co-authored-by: Michał Bartoszkiewicz <[email protected]> * eta alerting * . * proper sending * cleanup * Update projects/pathway/realtime/main.py * Update projects/pathway/realtime/main.py * yaml * fixes to tests * schema * comment --------- Co-authored-by: Jakub Kowalski <[email protected]> Co-authored-by: Michał Bartoszkiewicz <[email protected]> GitOrigin-RevId: f61d09079f6856dbd33fbc667d1cdace24f6d252
pathwaycom · Feb 12, 2024 · d6c2829 · d6c2829
1 parent 0505f06
commit d6c2829
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/python/pathway/internals/common.py b/python/pathway/internals/common.py
@@ -528,9 +528,10 @@ def table_transformer(
     locals: dict[str, Any] | None = None,
 ) -> Callable[P, T] | Callable[[Callable[P, T]], Callable[P, T]]:
     """
-    Decorator for marking that a function performs operations on Tables. As a consequence,
-    arguments and return value, which are annotated to have type pw.Table[S]
-    will be checked whether they indeed have schema S.
+    Marks a function that performs operations on Tables.
+
+    As a consequence, arguments and return value, which are annotated to have type pw.Table[S]
+    are checked whether they indeed have schema S.
 
     Args:
         allow_superset: if True, the columns of the table can be a superset of columns