From d6c2829f4b7c9a2c60f6d96b972f237cbbba201f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Przemys=C5=82aw=20Uzna=C5=84ski?= Date: Mon, 12 Feb 2024 10:32:28 +0100 Subject: [PATCH] alerting for ETA (#5579) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * 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 * 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 Co-authored-by: Michał Bartoszkiewicz GitOrigin-RevId: f61d09079f6856dbd33fbc667d1cdace24f6d252 --- python/pathway/internals/common.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/python/pathway/internals/common.py b/python/pathway/internals/common.py index 35ca46f8..c877e0aa 100644 --- 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