Add TypeError to exception when parsing last-update-time in bsqls ope…

…rator.
IndustryFusion · Aug 5, 2023 · 8eb93c5 · 8eb93c5
1 parent 697fb59
commit 8eb93c5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/FlinkSqlServicesOperator/beamsqlstatementsetoperator.py b/FlinkSqlServicesOperator/beamsqlstatementsetoperator.py
@@ -320,7 +320,7 @@ def monitor(beamsqltables: kopf.Index, beamsqlviews: kopf.Index,
             # if last_timestamp not defined, lookup the createdOn timestamp
             try:
                 last_timestamp = float(last_timestamp)
-            except ValueError:
+            except (ValueError, TypeError):
                 last_timestamp = None
             if last_timestamp is None:
                 create_obj = status_obj.get('create')