Skip to content

Commit ec32436

Browse files
committed
Fixed alert row deserialization
1 parent 138dd73 commit ec32436

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

monitor/alerts.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
import json
33
from exceptions.exceptions import InvalidAlertType
44
from utils.time import convert_utc_time_to_local_time
5+
from datetime import datetime
56

67

78
class Alert(object):
@@ -11,9 +12,10 @@ def __init__(self, alert_id) -> None:
1112
self.alert_id = alert_id
1213

1314
@staticmethod
14-
def create_alert_from_row(alert_row: list) -> 'Alert':
15+
def create_alert_from_row(alert_row: dict) -> 'Alert':
1516
alert_id, detected_at, database_name, schema_name, table_name, column_name, alert_type, sub_type, \
16-
alert_description = alert_row
17+
alert_description = alert_row.values()
18+
detected_at = datetime.fromisoformat(detected_at)
1719
if alert_type == 'schema_change':
1820
return SchemaChangeAlert(alert_id, database_name, schema_name, table_name, detected_at, sub_type,
1921
alert_description)

0 commit comments

Comments
 (0)