Skip to content
This repository has been archived by the owner on Dec 20, 2024. It is now read-only.

Commit

Permalink
Fix flow
Browse files Browse the repository at this point in the history
  • Loading branch information
bram-vdberg committed Nov 4, 2024
1 parent af99bfe commit 88e70b0
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions src/deploy_prefect/flows.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,9 @@ def dev_order_rewards() -> None:
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)
table_name = upload_data_to_dune(
data, blockrange.block_from, blockrange.block_to, config
)
update_aggregate_query(table_name, config)


Expand All @@ -31,5 +33,7 @@ def prod_order_rewards() -> None:
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)
table_name = upload_data_to_dune(
data, blockrange.block_from, blockrange.block_to, config
)
update_aggregate_query(table_name, config)

0 comments on commit 88e70b0

Please sign in to comment.