File tree Expand file tree Collapse file tree 2 files changed +8
-12
lines changed
dagster_open_platform/defs/pypi
dagster_open_platform_tests/__snapshots__ Expand file tree Collapse file tree 2 files changed +8
-12
lines changed Original file line number Diff line number Diff line change @@ -118,18 +118,11 @@ def dagster_pypi_downloads(
118
118
)
119
119
120
120
121
- oss_telemetry_events_raw = dg .SourceAsset (
122
- key = ["purina" , "prod_telemetry" , "oss_telemetry_events_raw" ],
123
- description = "OSS Telemetry events ingested from S3. The actual asset for this is currently in Purina until we can refactor the logic for it." ,
124
- group_name = "telemetry" ,
125
- )
126
-
127
-
128
121
@definitions
129
122
def defs ():
130
- return dg .Definitions (
131
- assets = [
132
- dagster_pypi_downloads ,
133
- oss_telemetry_events_raw ,
134
- ]
123
+ oss_telemetry_events_raw = dg .AssetSpec (
124
+ key = ["purina" , "prod_telemetry" , "oss_telemetry_events_raw" ],
125
+ description = "OSS Telemetry events ingested from S3. The actual asset for this is currently in Purina until we can refactor the logic for it." ,
126
+ group_name = "telemetry" ,
135
127
)
128
+ return dg .Definitions (assets = [oss_telemetry_events_raw , dagster_pypi_downloads ])
Original file line number Diff line number Diff line change 84848
84848
'pipelines_builds',
84849
84849
'product_operations/insights/reporting_asset_materialization_metrics',
84850
84850
'purina/oss_analytics/dagster_pypi_downloads',
84851
+ 'purina/prod_telemetry/oss_telemetry_events_raw',
84851
84852
'pylon/pylon/pylon_issues',
84852
84853
'sandbox//abm_activity_scoring',
84853
84854
'sandbox//abm_company_activity',
85457
85458
'pipelines_builds',
85458
85459
'product_operations/insights/reporting_asset_materialization_metrics',
85459
85460
'purina/oss_analytics/dagster_pypi_downloads',
85461
+ 'purina/prod_telemetry/oss_telemetry_events_raw',
85460
85462
'pylon/pylon/pylon_issues',
85461
85463
'sandbox//abm_activity_scoring',
85462
85464
'sandbox//abm_company_activity',
86190
86192
'pipelines_builds',
86191
86193
'product_operations/insights/reporting_asset_materialization_metrics',
86192
86194
'purina/oss_analytics/dagster_pypi_downloads',
86195
+ 'purina/prod_telemetry/oss_telemetry_events_raw',
86193
86196
'pylon/pylon/pylon_issues',
86194
86197
'sandbox//abm_activity_scoring',
86195
86198
'sandbox//abm_company_activity',
You can’t perform that action at this time.
0 commit comments