commit
5756cb15a5
@ -43,7 +43,7 @@ async def inspect_block(
|
|||||||
inspect_db_session: orm.Session,
|
inspect_db_session: orm.Session,
|
||||||
base_provider,
|
base_provider,
|
||||||
w3: Web3,
|
w3: Web3,
|
||||||
trace_clasifier: TraceClassifier,
|
trace_classifier: TraceClassifier,
|
||||||
block_number: int,
|
block_number: int,
|
||||||
trace_db_session: Optional[orm.Session],
|
trace_db_session: Optional[orm.Session],
|
||||||
should_write_classified_traces: bool = True,
|
should_write_classified_traces: bool = True,
|
||||||
@ -65,7 +65,7 @@ async def inspect_block(
|
|||||||
)
|
)
|
||||||
logger.info(f"Block: {block_number} -- Total transactions: {total_transactions}")
|
logger.info(f"Block: {block_number} -- Total transactions: {total_transactions}")
|
||||||
|
|
||||||
classified_traces = trace_clasifier.classify(block.traces)
|
classified_traces = trace_classifier.classify(block.traces)
|
||||||
logger.info(
|
logger.info(
|
||||||
f"Block: {block_number} -- Returned {len(classified_traces)} classified traces"
|
f"Block: {block_number} -- Returned {len(classified_traces)} classified traces"
|
||||||
)
|
)
|
||||||
|
@ -8,8 +8,8 @@ from .utils import load_test_block
|
|||||||
def test_arbitrage_real_block():
|
def test_arbitrage_real_block():
|
||||||
block = load_test_block(12914944)
|
block = load_test_block(12914944)
|
||||||
|
|
||||||
trace_clasifier = TraceClassifier()
|
trace_classifier = TraceClassifier()
|
||||||
classified_traces = trace_clasifier.classify(block.traces)
|
classified_traces = trace_classifier.classify(block.traces)
|
||||||
|
|
||||||
swaps = get_swaps(classified_traces)
|
swaps = get_swaps(classified_traces)
|
||||||
assert len(swaps) == 51
|
assert len(swaps) == 51
|
||||||
|
Loading…
x
Reference in New Issue
Block a user