Test pipeline

.github/workflows/prefect-dev.yaml

@@ -1,5 +1,6 @@
 name: prefect-dev
 on:
+  pull-request:
   push:
     branches: [ dev ]
 jobs:

.github/workflows/prefect-prod.yaml

@@ -1,7 +1,9 @@
 name: prefect-prod
 on:
+  pull_request:
   push:
-    branches: [ main ]
+    #branches: [ main ]
+    branches: [ dev ]
 jobs:
   prod-deployment:
     runs-on: ubuntu-latest

src/deploy_prefect/flows.py

@@ -1,6 +1,4 @@
 """Prefect Deployment for Order Rewards Data"""
-import os
-
 # pylint: disable=import-error
 from prefect import flow  # type: ignore
 
@@ -13,23 +11,9 @@
 )
 from src.deploy_prefect.models import ENV, CHAIN, Config
 
-def generate_pr_flow_name():
-    return os.getenv("BRANCH_NAME")
-
-@flow(flow_run_name=generate_pr_flow_name, retries=3, retry_delay_seconds=60, log_prints=True)  # type: ignore[misc]
-def dev_order_rewards() -> None:
-    """Defines a flow for updating the order_rewards table"""
-    config = Config(CHAIN.MAINNET, ENV.DEV)
-
-    blockrange = get_block_range()
-    orderbook = fetch_orderbook(blockrange)
-    data = cast_orderbook_to_dune_string(orderbook)
-    table_name = upload_data_to_dune(data, blockrange.block_from, blockrange.block_to)
-    update_aggregate_query(table_name, config)
-
 
 @flow(retries=3, retry_delay_seconds=60, log_prints=True)  # type: ignore[misc]
-def tmp_dev_order_rewards() -> None:
+def dev_order_rewards() -> None:
     """Defines a flow for updating the order_rewards table"""
     config = Config(CHAIN.MAINNET, ENV.DEV)