Skip to content

Commit 32d52c7

Browse files
committed
changes
1 parent 752cf7c commit 32d52c7

File tree

2 files changed

+21
-3
lines changed

2 files changed

+21
-3
lines changed

src/vendor/dbt_artifacts_parser/parsers/run_results/run_results_v6.py

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,12 @@ class BatchResults(BaseParserModel):
6464
failed: Optional[list[list]] = None
6565

6666

67+
class AdapterResponse(BaseParserModel):
68+
model_config = ConfigDict(
69+
extra="allow",
70+
)
71+
72+
6773
class Result(BaseParserModel):
6874
model_config = ConfigDict(
6975
extra="allow",
@@ -72,7 +78,7 @@ class Result(BaseParserModel):
7278
timing: list[TimingItem]
7379
thread_id: str
7480
execution_time: float
75-
adapter_response: dict[str, Any]
81+
adapter_response: AdapterResponse
7682
message: Optional[str] = None
7783
failures: Optional[int] = None
7884
unique_id: str
@@ -82,11 +88,17 @@ class Result(BaseParserModel):
8288
batch_results: Optional[BatchResults] = None
8389

8490

91+
class Args(BaseParserModel):
92+
model_config = ConfigDict(
93+
extra="allow",
94+
)
95+
96+
8597
class RunResultsV6(BaseParserModel):
8698
model_config = ConfigDict(
8799
extra="allow",
88100
)
89101
metadata: Metadata = Field(..., title="BaseArtifactMetadata")
90102
results: list[Result]
91103
elapsed_time: float
92-
args: Optional[dict[str, Any]] = None
104+
args: Optional[Args] = None

src/vendor/dbt_artifacts_parser/parsers/sources/sources_v3.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,12 @@ class TimingItem(BaseParserModel):
8585
completed_at: Optional[str] = None
8686

8787

88+
class AdapterResponse(BaseParserModel):
89+
model_config = ConfigDict(
90+
extra="allow",
91+
)
92+
93+
8894
class Results1(BaseParserModel):
8995
model_config = ConfigDict(
9096
extra="allow",
@@ -95,7 +101,7 @@ class Results1(BaseParserModel):
95101
max_loaded_at_time_ago_in_s: float
96102
status: Status1
97103
criteria: Criteria = Field(..., title="FreshnessThreshold")
98-
adapter_response: dict[str, Any]
104+
adapter_response: AdapterResponse
99105
timing: list[TimingItem]
100106
thread_id: str
101107
execution_time: float

0 commit comments

Comments
 (0)