| 200 | ) |
| 201 | |
| 202 | def create_job_node(self, graph, jobs): |
| 203 | job_identifier = f"{graph.id}_job" |
| 204 | self.tree.create_node(tag="job", identifier=job_identifier, parent=graph.id) |
| 205 | for j in jobs: |
| 206 | if j.detail["graph_id"] != graph.id: |
| 207 | continue |
| 208 | self.tree.create_node( |
| 209 | tag="Job(identifier: {0}, type: {1}, status: {2}, start time: {3}, end time: {4})".format( |
| 210 | j.id, j.type, j.status, j.start_time, str(j.end_time) |
| 211 | ), |
| 212 | identifier=f"{job_identifier}_{j.id}", |
| 213 | parent=job_identifier, |
| 214 | ) |
| 215 | |
| 216 | def create_datasource_mapping_node(self, graph, datasource_mapping): |
| 217 | datasource_identifier = f"{graph.id}_datasource" |