@@ -34,6 +34,7 @@ def __init__(
34
34
workbook_id : Optional [str ] = None ,
35
35
datasource_id : Optional [str ] = None ,
36
36
flow_run : Optional [FlowRunItem ] = None ,
37
+ updated_at : Optional ["datetime.datetime" ] = None ,
37
38
):
38
39
self ._id = id_
39
40
self ._type = job_type
@@ -47,6 +48,7 @@ def __init__(
47
48
self ._workbook_id = workbook_id
48
49
self ._datasource_id = datasource_id
49
50
self ._flow_run = flow_run
51
+ self ._updated_at = updated_at
50
52
51
53
@property
52
54
def id (self ) -> str :
@@ -113,9 +115,13 @@ def flow_run(self):
113
115
def flow_run (self , value ):
114
116
self ._flow_run = value
115
117
118
+ @property
119
+ def updated_at (self ) -> Optional ["datetime.datetime" ]:
120
+ return self ._updated_at
121
+
116
122
def __repr__ (self ):
117
123
return (
118
- "<Job#{_id} {_type} created_at({_created_at}) started_at({_started_at}) completed_at({_completed_at})"
124
+ "<Job#{_id} {_type} created_at({_created_at}) started_at({_started_at}) updated_at({_updated_at}) completed_at({_completed_at})"
119
125
" progress ({_progress}) finish_code({_finish_code})>" .format (** self .__dict__ )
120
126
)
121
127
@@ -144,6 +150,7 @@ def _parse_element(cls, element, ns):
144
150
datasource = element .find (".//t:datasource[@id]" , namespaces = ns )
145
151
8000
datasource_id = datasource .get ("id" ) if datasource is not None else None
146
152
flow_run = None
153
+ updated_at = parse_datetime (element .get ("updatedAt" , None ))
147
154
for flow_job in element .findall (".//t:runFlowJobType" , namespaces = ns ):
148
155
flow_run = FlowRunItem ()
149
156
flow_run ._id = flow_job .get ("flowRunId" , None )
@@ -163,6 +170,7 @@ def _parse_element(cls, element, ns):
163
170
workbook_id ,
164
171
datasource_id ,
165
172
flow_run ,
173
+ updated_at ,
166
174
)
167
175
168
176
0 commit comments