Skip to content
This repository has been archived by the owner on Nov 16, 2022. It is now read-only.

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
Benzbeeb committed Aug 19, 2020
1 parent 878715d commit 7befa32
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions flusher/flusher/init.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,7 @@ def init(chain_id, topic, db):
"""Initialize database with empty tables and tracking info."""
engine = create_engine("postgresql+psycopg2://" + db, echo=True)
metadata.create_all(engine)
engine.execute(tracking.insert(), {
"chain_id": chain_id, "topic": topic, "kafka_offset": -1})
engine.execute(tracking.insert(), {"chain_id": chain_id, "topic": topic, "kafka_offset": -1})
engine.execute(
"""CREATE VIEW delegations_view AS
SELECT CAST(shares AS DECIMAL) * CAST(tokens AS DECIMAL) / CAST(delegator_shares AS DECIMAL) as amount,
Expand Down

0 comments on commit 7befa32

Please sign in to comment.