Commit d922879 1 parent 39ce889 commit d922879 Copy full SHA for d922879
File tree 2 files changed +4
-4
lines changed
src/datahub/api/entities/dataprocess
tests/unit/stateful_ingestion/state
2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 14
14
RunResultType ,
15
15
)
16
16
from datahub .metadata .schema_classes import (
17
- AuditStampClass ,
18
17
DataProcessInstanceRunEventClass ,
19
18
DataProcessInstanceRunResultClass ,
20
19
DataProcessRunStatusClass ,
21
20
DataProcessTypeClass ,
21
+ TimeStampClass ,
22
22
)
23
23
from datahub .utilities .str_enum import StrEnum
24
24
from datahub .utilities .urns .data_flow_urn import DataFlowUrn
@@ -244,7 +244,7 @@ def generate_mcp(
244
244
entityUrn = str (self .urn ),
245
245
aspect = DataProcessInstanceProperties (
246
246
name = self .id ,
247
- created = AuditStampClass (
247
+ created = TimeStampClass (
248
248
time = created_ts_millis or int (time .time () * 1000 ),
249
249
actor = "urn:li:corpuser:datahub" ,
250
250
),
Original file line number Diff line number Diff line change 31
31
DataProcessInstanceProperties ,
32
32
)
33
33
from datahub .metadata .schema_classes import (
34
- AuditStampClass ,
35
34
DataPlatformInstanceClass ,
36
35
StatusClass ,
36
+ TimeStampClass ,
37
37
)
38
38
from datahub .metadata .urns import DataPlatformUrn , QueryUrn
39
39
from datahub .utilities .urns .dataset_urn import DatasetUrn
@@ -137,7 +137,7 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
137
137
entityUrn = str (dpi .urn ),
138
138
aspect = DataProcessInstanceProperties (
139
139
name = dpi .id ,
140
- created = AuditStampClass (
140
+ created = TimeStampClass (
141
141
time = int (time .time () * 1000 ),
142
142
actor = "urn:li:corpuser:datahub" ,
143
143
),
You can’t perform that action at this time.
0 commit comments