Merge pull request #87 from cowprotocol/remove_internal_imbalances_job

Remove internal imbalances job
cowprotocol · Mar 5, 2024 · a017ea7 · a017ea7
2 parents abfc588 + 7183713
commit a017ea7
Show file tree

Hide file tree

Showing 10 changed files with 0 additions and 243 deletions.
diff --git a/.github/workflows/pull-request.yaml b/.github/workflows/pull-request.yaml
@@ -49,4 +49,3 @@ jobs:
         env:
           PROD_DB_URL: ${{ secrets.PROD_DB_URL }}
           BARN_DB_URL: ${{ secrets.BARN_DB_URL }}
-          WAREHOUSE_URL: ${{ secrets.WAREHOUSE_URL }}
diff --git a/src/fetch/postgres.py b/src/fetch/postgres.py
diff --git a/src/main.py b/src/main.py
@@ -9,14 +9,12 @@
 
 from src.fetch.dune import DuneFetcher
 from src.fetch.orderbook import OrderbookFetcher
-from src.fetch.postgres import PostgresFetcher
 from src.logger import set_log
 from src.models.tables import SyncTable
 from src.post.aws import AWSClient
 from src.sync import sync_app_data
 from src.sync.config import SyncConfig, AppDataSyncConfig
 from src.sync.order_rewards import sync_order_rewards, sync_batch_rewards
-from src.sync.token_imbalance import sync_internal_imbalance
 
 log = set_log(__name__)
 
@@ -84,12 +82,5 @@ def __init__(self) -> None:
             fetcher=OrderbookFetcher(),
             dry_run=args.dry_run,
         )
-    elif args.sync_table == SyncTable.INTERNAL_IMBALANCE:
-        sync_internal_imbalance(
-            aws,
-            config=SyncConfig(volume_path),
-            fetcher=PostgresFetcher(os.environ["WAREHOUSE_URL"]),
-            dry_run=args.dry_run,
-        )
     else:
         log.error(f"unsupported sync_table '{args.sync_table}'")
diff --git a/src/models/tables.py b/src/models/tables.py
@@ -8,7 +8,6 @@ class SyncTable(Enum):
     APP_DATA = "app_data"
     ORDER_REWARDS = "order_rewards"
     BATCH_REWARDS = "batch_rewards"
-    INTERNAL_IMBALANCE = "internal_imbalance"
 
     def __str__(self) -> str:
         return str(self.value)

diff --git a/src/models/token_imbalance_schema.py b/src/models/token_imbalance_schema.py
diff --git a/src/sql/warehouse/latest_block.sql b/src/sql/warehouse/latest_block.sql
diff --git a/src/sql/warehouse/token_imbalances.sql b/src/sql/warehouse/token_imbalances.sql
diff --git a/src/sync/token_imbalance.py b/src/sync/token_imbalance.py
diff --git a/tests/integration/test_warehouse_fetcher.py b/tests/integration/test_warehouse_fetcher.py
diff --git a/tests/unit/test_token_imbalance_schema.py b/tests/unit/test_token_imbalance_schema.py