Skip to content

Commit de10e1c

Browse files
committed
fix: unpack load_sink_events return value
1 parent ccf525d commit de10e1c

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

sc_audit/cli.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -178,11 +178,11 @@ def db_load_distribution_outflows():
178178
@load.command(name="sinking-txs")
179179
def db_load_sinking_txs():
180180
"""Load sinking transactions into the DB"""
181-
sink_cursor = get_latest_attr('sink_tx')
182-
num_sinking_txs = load_sinking_txs(cursor=sink_cursor) # type: ignore[arg-type]
181+
sink_cursor: int = get_latest_attr('sink_tx') # type: ignore[return-value]
182+
num_sinking_txs = load_sinking_txs(cursor=sink_cursor)
183183
click.echo(f"Loaded {num_sinking_txs} sinking transactions")
184184
try:
185-
num_sink_events = load_sink_events(cursor=sink_cursor) # type: ignore[arg-type]
185+
num_sink_events, _ = load_sink_events(cursor=sink_cursor)
186186
print(f"Loaded {num_sink_events} sink events")
187187
except MercuryError as exc:
188188
click.echo(f"Couldn't load sink events from Mercury")

sc_audit/loader/__main__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ def catch_up_from_sources():
5252
num_sinking_txs = load_sinking_txs(cursor=sink_cursor)
5353
print(f"Loaded {num_sinking_txs} sinking transactions")
5454
try:
55-
num_sink_events = load_sink_events(cursor=sink_cursor) # type: ignore[arg-type]
55+
num_sink_events, _ = load_sink_events(cursor=sink_cursor)
5656
print(f"Loaded {num_sink_events} sink events")
5757
except MercuryError as exc:
5858
print(f"Couldn't load sink events from Mercury")

0 commit comments

Comments
 (0)