From 65f2f9fdc6e02a18706081b154b4615e0fb111f7 Mon Sep 17 00:00:00 2001 From: Reuven Gonzales Date: Mon, 16 Sep 2024 12:17:32 -0700 Subject: [PATCH] Fixes arbitrum traces (#2158) --- warehouse/oso_dagster/assets/arbitrum.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/warehouse/oso_dagster/assets/arbitrum.py b/warehouse/oso_dagster/assets/arbitrum.py index d5e82c678..4388026f5 100644 --- a/warehouse/oso_dagster/assets/arbitrum.py +++ b/warehouse/oso_dagster/assets/arbitrum.py @@ -1,11 +1,9 @@ -from oso_dagster.utils import unpack_config, gcs_to_bucket_name -from ..factories.goldsky.config import GoldskyNetworkConfig, NetworkAssetSourceConfig +from oso_dagster.utils import gcs_to_bucket_name, unpack_config + +from ..factories.common import AssetFactoryResponse, early_resources_asset_factory +from ..factories.goldsky.additional import blocks_extensions, transactions_extensions from ..factories.goldsky.assets import goldsky_asset -from ..factories.common import early_resources_asset_factory, AssetFactoryResponse -from ..factories.goldsky.additional import ( - blocks_extensions, - transactions_extensions, -) +from ..factories.goldsky.config import GoldskyNetworkConfig, NetworkAssetSourceConfig @unpack_config(GoldskyNetworkConfig) @@ -97,7 +95,9 @@ def _factory(project_id: str, staging_bucket: str): source_name=f"{config.network_name}-traces", partition_column_name="block_timestamp", partition_column_transform=lambda t: f"TIMESTAMP_SECONDS(`{t}`)", - schema_overrides=[], + schema_overrides=[ + {"name": "value", "field_type": "BYTES"}, + ], external_reference="", ), config.traces_config,