From 586333e12fbe3e1a40fd42d1ca1eed431ff9cd85 Mon Sep 17 00:00:00 2001 From: Andrey Date: Mon, 15 Jul 2024 16:31:38 +0300 Subject: [PATCH 1/7] Add migration. --- .../38ad819f94ed_bytea_address_in_labels.py | 220 ++++++++++++++++++ moonstreamdb-v3/moonstreamdbv3/models.py | 5 +- 2 files changed, 223 insertions(+), 2 deletions(-) create mode 100644 moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py diff --git a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py new file mode 100644 index 00000000..b1ec64e9 --- /dev/null +++ b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py @@ -0,0 +1,220 @@ +"""Bytea address in labels + +Revision ID: 38ad819f94ed +Revises: 792ca9c4722c +Create Date: 2024-07-15 16:16:35.400430 + +""" +from typing import Sequence, Union + +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision: str = '38ad819f94ed' +down_revision: Union[str, None] = '792ca9c4722c' +branch_labels: Union[str, Sequence[str], None] = None +depends_on: Union[str, Sequence[str], None] = None + + +def upgrade() -> None: + # ### commands auto generated by Alembic - please adjust! ### + op.alter_column('amoy_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('arbitrum_nova_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('arbitrum_one_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('arbitrum_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('avalanche_fuji_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('avalanche_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('base_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('blast_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('blast_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('ethereum_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('mantle_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('mantle_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('mumbai_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('polygon_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('proofofplay_apex_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('starknet_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('starknet_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('xai_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('xai_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('xdai_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('zksync_era_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('zksync_era_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + # ### end Alembic commands ### + + +def downgrade() -> None: + # ### commands auto generated by Alembic - please adjust! ### + op.alter_column('zksync_era_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('zksync_era_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('xdai_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('xai_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('xai_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('starknet_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('starknet_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('proofofplay_apex_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('polygon_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('mumbai_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('mantle_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('mantle_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('ethereum_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('blast_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('blast_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('base_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('avalanche_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('avalanche_fuji_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('arbitrum_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('arbitrum_one_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('arbitrum_nova_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('amoy_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + # ### end Alembic commands ### diff --git a/moonstreamdb-v3/moonstreamdbv3/models.py b/moonstreamdb-v3/moonstreamdbv3/models.py index debee995..4c45d67f 100644 --- a/moonstreamdb-v3/moonstreamdbv3/models.py +++ b/moonstreamdb-v3/moonstreamdbv3/models.py @@ -26,6 +26,7 @@ Integer, MetaData, Text, + LargeBinary, ) from sqlalchemy.dialects.postgresql import JSONB, UUID from sqlalchemy.ext.compiler import compiles @@ -103,8 +104,8 @@ class EvmBasedLabel(Base): # type: ignore index=True, ) address = Column( - VARCHAR(64), - nullable=True, + LargeBinary, + nullable=False, index=True, ) From 2d8ca7f90edcbb680211a95b63dd0402eb654847 Mon Sep 17 00:00:00 2001 From: Andrey Date: Mon, 15 Jul 2024 17:28:35 +0300 Subject: [PATCH 2/7] Add insert change. --- crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py b/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py index 43a81955..85807dbe 100644 --- a/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py +++ b/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py @@ -265,7 +265,7 @@ def add_events_to_session( "block_timestamp": label_event.block_timestamp, "caller_address": None, "origin_address": None, - "address": label_event.address, + "address": bytes.fromhex(label_event.address[2:]), "label_name": label_event.label_name, "label_type": "event", "label_data": label_event.label_data, @@ -357,7 +357,7 @@ def add_function_calls_to_session( "block_timestamp": label_function_call.block_timestamp, "caller_address": label_function_call.caller_address, "origin_address": label_function_call.caller_address, - "address": label_function_call.address, + "address": bytes.fromhex(label_function_call.address[2:]), "label_name": label_function_call.label_name, "label_type": "tx_call", "label_data": label_function_call.label_data, From 51b4ea4f4b2113cf3fa36123eaff0b5d6eb1e365 Mon Sep 17 00:00:00 2001 From: Andrey Date: Mon, 15 Jul 2024 17:40:07 +0300 Subject: [PATCH 3/7] Change address format. --- .../mooncrawl/moonworm_crawler/db.py | 4 +- .../2e90b758090c_bytea_address_in_labels.py | 604 ++++++++++++++++++ .../38ad819f94ed_bytea_address_in_labels.py | 220 ------- moonstreamdb-v3/moonstreamdbv3/models.py | 5 +- 4 files changed, 609 insertions(+), 224 deletions(-) create mode 100644 moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py delete mode 100644 moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py diff --git a/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py b/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py index 85807dbe..8f1ecd26 100644 --- a/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py +++ b/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py @@ -355,8 +355,8 @@ def add_function_calls_to_session( "block_number": label_function_call.block_number, "block_hash": label_function_call.block_hash, "block_timestamp": label_function_call.block_timestamp, - "caller_address": label_function_call.caller_address, - "origin_address": label_function_call.caller_address, + "caller_address": bytes.fromhex(label_function_call.caller_address[2:]), + "origin_address": bytes.fromhex(label_function_call.caller_address[2:]), "address": bytes.fromhex(label_function_call.address[2:]), "label_name": label_function_call.label_name, "label_type": "tx_call", diff --git a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py new file mode 100644 index 00000000..71571574 --- /dev/null +++ b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py @@ -0,0 +1,604 @@ +"""Bytea address in labels + +Revision ID: 2e90b758090c +Revises: 792ca9c4722c +Create Date: 2024-07-15 17:38:36.529835 + +""" +from typing import Sequence, Union + +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision: str = '2e90b758090c' +down_revision: Union[str, None] = '792ca9c4722c' +branch_labels: Union[str, Sequence[str], None] = None +depends_on: Union[str, Sequence[str], None] = None + + +def upgrade() -> None: + # ### commands auto generated by Alembic - please adjust! ### + op.alter_column('amoy_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('amoy_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('amoy_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('arbitrum_nova_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('arbitrum_nova_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('arbitrum_nova_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('arbitrum_one_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('arbitrum_one_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('arbitrum_one_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('arbitrum_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('arbitrum_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('arbitrum_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('avalanche_fuji_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('avalanche_fuji_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('avalanche_fuji_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('avalanche_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('avalanche_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('avalanche_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('base_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('base_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('base_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('blast_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('blast_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('blast_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('blast_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('blast_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('blast_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('ethereum_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('ethereum_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('ethereum_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('mantle_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('mantle_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('mantle_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('mantle_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('mantle_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('mantle_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('mumbai_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('mumbai_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('mumbai_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('polygon_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('polygon_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('polygon_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('proofofplay_apex_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('proofofplay_apex_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('proofofplay_apex_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('starknet_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('starknet_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('starknet_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('starknet_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('starknet_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('starknet_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('xai_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('xai_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('xai_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('xai_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('xai_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('xai_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('xdai_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('xdai_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('xdai_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('zksync_era_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('zksync_era_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('zksync_era_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + op.alter_column('zksync_era_sepolia_labels', 'caller_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('zksync_era_sepolia_labels', 'origin_address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + existing_nullable=True) + op.alter_column('zksync_era_sepolia_labels', 'address', + existing_type=sa.VARCHAR(length=64), + type_=sa.LargeBinary(), + nullable=False) + # ### end Alembic commands ### + + +def downgrade() -> None: + # ### commands auto generated by Alembic - please adjust! ### + op.alter_column('zksync_era_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('zksync_era_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('zksync_era_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('zksync_era_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('zksync_era_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('zksync_era_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('xdai_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('xdai_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('xdai_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('xai_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('xai_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('xai_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('xai_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('xai_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('xai_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('starknet_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('starknet_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('starknet_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('starknet_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('starknet_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('starknet_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('proofofplay_apex_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('proofofplay_apex_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('proofofplay_apex_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('polygon_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('polygon_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('polygon_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('mumbai_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('mumbai_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('mumbai_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('mantle_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('mantle_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('mantle_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('mantle_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('mantle_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('mantle_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('ethereum_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('ethereum_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('ethereum_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('blast_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('blast_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('blast_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('blast_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('blast_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('blast_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('base_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('base_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('base_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('avalanche_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('avalanche_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('avalanche_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('avalanche_fuji_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('avalanche_fuji_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('avalanche_fuji_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('arbitrum_sepolia_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('arbitrum_sepolia_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('arbitrum_sepolia_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('arbitrum_one_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('arbitrum_one_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('arbitrum_one_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('arbitrum_nova_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('arbitrum_nova_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('arbitrum_nova_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('amoy_labels', 'address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True) + op.alter_column('amoy_labels', 'origin_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + op.alter_column('amoy_labels', 'caller_address', + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True) + # ### end Alembic commands ### diff --git a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py deleted file mode 100644 index b1ec64e9..00000000 --- a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/38ad819f94ed_bytea_address_in_labels.py +++ /dev/null @@ -1,220 +0,0 @@ -"""Bytea address in labels - -Revision ID: 38ad819f94ed -Revises: 792ca9c4722c -Create Date: 2024-07-15 16:16:35.400430 - -""" -from typing import Sequence, Union - -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision: str = '38ad819f94ed' -down_revision: Union[str, None] = '792ca9c4722c' -branch_labels: Union[str, Sequence[str], None] = None -depends_on: Union[str, Sequence[str], None] = None - - -def upgrade() -> None: - # ### commands auto generated by Alembic - please adjust! ### - op.alter_column('amoy_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('arbitrum_nova_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('arbitrum_one_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('arbitrum_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('avalanche_fuji_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('avalanche_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('base_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('blast_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('blast_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('ethereum_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('mantle_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('mantle_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('mumbai_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('polygon_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('proofofplay_apex_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('starknet_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('starknet_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('xai_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('xai_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('xdai_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('zksync_era_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('zksync_era_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - # ### end Alembic commands ### - - -def downgrade() -> None: - # ### commands auto generated by Alembic - please adjust! ### - op.alter_column('zksync_era_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('zksync_era_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('xdai_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('xai_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('xai_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('starknet_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('starknet_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('proofofplay_apex_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('polygon_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('mumbai_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('mantle_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('mantle_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('ethereum_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('blast_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('blast_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('base_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('avalanche_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('avalanche_fuji_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('arbitrum_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('arbitrum_one_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('arbitrum_nova_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('amoy_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - # ### end Alembic commands ### diff --git a/moonstreamdb-v3/moonstreamdbv3/models.py b/moonstreamdb-v3/moonstreamdbv3/models.py index 4c45d67f..781c887f 100644 --- a/moonstreamdb-v3/moonstreamdbv3/models.py +++ b/moonstreamdb-v3/moonstreamdbv3/models.py @@ -94,15 +94,16 @@ class EvmBasedLabel(Base): # type: ignore block_timestamp = Column(BigInteger, nullable=False) caller_address = Column( - VARCHAR(64), + LargeBinary, nullable=True, index=True, ) origin_address = Column( - VARCHAR(64), + LargeBinary, nullable=True, index=True, ) + address = Column( LargeBinary, nullable=False, From 5b6e23c2ce9a10ea7cc5d85a1a9a85053d5cc732 Mon Sep 17 00:00:00 2001 From: Andrey Date: Mon, 15 Jul 2024 21:48:03 +0300 Subject: [PATCH 4/7] Add fix for upgrade. --- .../2e90b758090c_bytea_address_in_labels.py | 1301 +++++++++-------- 1 file changed, 723 insertions(+), 578 deletions(-) diff --git a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py index 71571574..d2e4e61d 100644 --- a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py +++ b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py @@ -5,6 +5,7 @@ Create Date: 2024-07-15 17:38:36.529835 """ + from typing import Sequence, Union from alembic import op @@ -12,593 +13,737 @@ # revision identifiers, used by Alembic. -revision: str = '2e90b758090c' -down_revision: Union[str, None] = '792ca9c4722c' +revision: str = "2e90b758090c" +down_revision: Union[str, None] = "792ca9c4722c" branch_labels: Union[str, Sequence[str], None] = None depends_on: Union[str, Sequence[str], None] = None def upgrade() -> None: # ### commands auto generated by Alembic - please adjust! ### - op.alter_column('amoy_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('amoy_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('amoy_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('arbitrum_nova_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('arbitrum_nova_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('arbitrum_nova_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('arbitrum_one_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('arbitrum_one_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('arbitrum_one_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('arbitrum_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('arbitrum_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('arbitrum_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('avalanche_fuji_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('avalanche_fuji_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('avalanche_fuji_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('avalanche_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('avalanche_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('avalanche_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('base_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('base_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('base_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('blast_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('blast_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('blast_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('blast_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('blast_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('blast_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('ethereum_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('ethereum_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('ethereum_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('mantle_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('mantle_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('mantle_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('mantle_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('mantle_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('mantle_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('mumbai_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('mumbai_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('mumbai_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('polygon_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('polygon_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('polygon_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('proofofplay_apex_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('proofofplay_apex_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('proofofplay_apex_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('starknet_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('starknet_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('starknet_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('starknet_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('starknet_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('starknet_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('xai_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('xai_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('xai_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('xai_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('xai_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('xai_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('xdai_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('xdai_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('xdai_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('zksync_era_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('zksync_era_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('zksync_era_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) - op.alter_column('zksync_era_sepolia_labels', 'caller_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('zksync_era_sepolia_labels', 'origin_address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - existing_nullable=True) - op.alter_column('zksync_era_sepolia_labels', 'address', - existing_type=sa.VARCHAR(length=64), - type_=sa.LargeBinary(), - nullable=False) + op.execute( + "ALTER TABLE amoy_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE amoy_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE amoy_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_nova_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_nova_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_nova_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_one_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_one_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_one_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE arbitrum_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE avalanche_fuji_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE avalanche_fuji_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE avalanche_fuji_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE avalanche_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE avalanche_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE avalanche_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE base_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE base_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE base_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE blast_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE blast_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE blast_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE blast_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE blast_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE blast_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE ethereum_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE ethereum_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE ethereum_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE game7_orbit_arbitrum_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE game7_orbit_arbitrum_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE game7_orbit_arbitrum_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE mantle_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE mantle_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE mantle_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE mantle_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE mantle_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE mantle_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE mumbai_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE mumbai_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE mumbai_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE polygon_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE polygon_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE polygon_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE proofofplay_apex_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE proofofplay_apex_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE proofofplay_apex_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE starknet_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE starknet_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE starknet_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE starknet_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE starknet_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE starknet_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE xai_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE xai_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE xai_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE xai_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE xai_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE xai_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE xdai_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE xdai_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE xdai_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE zksync_era_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE zksync_era_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE zksync_era_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) + op.execute( + "ALTER TABLE zksync_era_sepolia_labels ALTER COLUMN caller_address TYPE bytea USING caller_address::bytea" + ) + op.execute( + "ALTER TABLE zksync_era_sepolia_labels ALTER COLUMN origin_address TYPE bytea USING origin_address::bytea" + ) + op.execute( + "ALTER TABLE zksync_era_sepolia_labels ALTER COLUMN address TYPE bytea USING address::bytea" + ) # ### end Alembic commands ### def downgrade() -> None: # ### commands auto generated by Alembic - please adjust! ### - op.alter_column('zksync_era_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('zksync_era_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('zksync_era_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('zksync_era_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('zksync_era_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('zksync_era_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('xdai_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('xdai_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('xdai_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('xai_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('xai_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('xai_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('xai_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('xai_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('xai_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('starknet_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('starknet_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('starknet_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('starknet_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('starknet_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('starknet_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('proofofplay_apex_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('proofofplay_apex_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('proofofplay_apex_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('polygon_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('polygon_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('polygon_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('mumbai_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('mumbai_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('mumbai_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('mantle_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('mantle_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('mantle_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('mantle_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('mantle_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('mantle_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('game7_orbit_arbitrum_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('ethereum_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('ethereum_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('ethereum_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('blast_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('blast_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('blast_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('blast_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('blast_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('blast_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('base_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('base_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('base_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('avalanche_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('avalanche_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('avalanche_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('avalanche_fuji_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('avalanche_fuji_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('avalanche_fuji_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('arbitrum_sepolia_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('arbitrum_sepolia_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('arbitrum_sepolia_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('arbitrum_one_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('arbitrum_one_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('arbitrum_one_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('arbitrum_nova_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('arbitrum_nova_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('arbitrum_nova_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('amoy_labels', 'address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - nullable=True) - op.alter_column('amoy_labels', 'origin_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) - op.alter_column('amoy_labels', 'caller_address', - existing_type=sa.LargeBinary(), - type_=sa.VARCHAR(length=64), - existing_nullable=True) + op.alter_column( + "zksync_era_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "zksync_era_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "zksync_era_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "zksync_era_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "zksync_era_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "zksync_era_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "xdai_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "xdai_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "xdai_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "xai_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "xai_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "xai_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "xai_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "xai_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "xai_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "starknet_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "starknet_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "starknet_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "starknet_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "starknet_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "starknet_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "proofofplay_apex_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "proofofplay_apex_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "proofofplay_apex_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "polygon_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "polygon_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "polygon_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "mumbai_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "mumbai_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "mumbai_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "mantle_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "mantle_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "mantle_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "mantle_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "mantle_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "mantle_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "game7_orbit_arbitrum_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "game7_orbit_arbitrum_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "game7_orbit_arbitrum_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "ethereum_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "ethereum_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "ethereum_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "blast_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "blast_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "blast_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "blast_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "blast_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "blast_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "base_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "base_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "base_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "avalanche_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "avalanche_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "avalanche_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "avalanche_fuji_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "avalanche_fuji_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "avalanche_fuji_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "arbitrum_sepolia_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "arbitrum_sepolia_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "arbitrum_sepolia_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "arbitrum_one_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "arbitrum_one_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "arbitrum_one_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "arbitrum_nova_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "arbitrum_nova_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "arbitrum_nova_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "amoy_labels", + "address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + nullable=True, + ) + op.alter_column( + "amoy_labels", + "origin_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) + op.alter_column( + "amoy_labels", + "caller_address", + existing_type=sa.LargeBinary(), + type_=sa.VARCHAR(length=64), + existing_nullable=True, + ) # ### end Alembic commands ### From 6b1d40c8737dbb400a05a96df33816125157e92c Mon Sep 17 00:00:00 2001 From: Andrey Date: Mon, 15 Jul 2024 22:35:05 +0300 Subject: [PATCH 5/7] git push --- .../alembic/versions/2e90b758090c_bytea_address_in_labels.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py index d2e4e61d..6273026c 100644 --- a/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py +++ b/moonstreamdb-v3/moonstreamdbv3/alembic/versions/2e90b758090c_bytea_address_in_labels.py @@ -14,7 +14,7 @@ # revision identifiers, used by Alembic. revision: str = "2e90b758090c" -down_revision: Union[str, None] = "792ca9c4722c" +down_revision: Union[str, None] = "9ca39b11e12a" branch_labels: Union[str, Sequence[str], None] = None depends_on: Union[str, Sequence[str], None] = None From 422933bb4c2c5946a99d8af970deb5e5d5f37345 Mon Sep 17 00:00:00 2001 From: Andrey Date: Tue, 16 Jul 2024 00:05:15 +0300 Subject: [PATCH 6/7] Fix label. --- crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py b/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py index 8f1ecd26..05e8f16c 100644 --- a/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py +++ b/crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py @@ -345,7 +345,7 @@ def add_function_calls_to_session( for function_call in function_calls: label_function_call = _function_call_to_label( - blockchain_type, function_call, db_version + blockchain_type, function_call, db_version, label_name ) record = { From 51665961134997e374e01cff374f2a1385e1ce39 Mon Sep 17 00:00:00 2001 From: Andrey Date: Tue, 16 Jul 2024 00:10:19 +0300 Subject: [PATCH 7/7] Bump versions. --- crawlers/mooncrawl/mooncrawl/version.py | 2 +- crawlers/mooncrawl/setup.py | 2 +- moonstreamdb-v3/moonstreamdbv3/version.txt | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/crawlers/mooncrawl/mooncrawl/version.py b/crawlers/mooncrawl/mooncrawl/version.py index 2ea34e26..d300c78a 100644 --- a/crawlers/mooncrawl/mooncrawl/version.py +++ b/crawlers/mooncrawl/mooncrawl/version.py @@ -2,4 +2,4 @@ Moonstream crawlers version. """ -MOONCRAWL_VERSION = "0.4.9" +MOONCRAWL_VERSION = "0.4.10" diff --git a/crawlers/mooncrawl/setup.py b/crawlers/mooncrawl/setup.py index 3e57aadf..dd767890 100644 --- a/crawlers/mooncrawl/setup.py +++ b/crawlers/mooncrawl/setup.py @@ -38,7 +38,7 @@ "chardet", "fastapi", "moonstreamdb>=0.4.5", - "moonstreamdb-v3>=0.0.11", + "moonstreamdb-v3>=0.0.13", "moonstream-types>=0.0.4", "moonstream>=0.1.1", "moonworm[moonstream]>=0.9.2", diff --git a/moonstreamdb-v3/moonstreamdbv3/version.txt b/moonstreamdb-v3/moonstreamdbv3/version.txt index 8cbf02c3..43b29618 100644 --- a/moonstreamdb-v3/moonstreamdbv3/version.txt +++ b/moonstreamdb-v3/moonstreamdbv3/version.txt @@ -1 +1 @@ -0.0.12 +0.0.13