kamikazechaser/cic-internal-integration
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Correct progress callback

Browse Source
This commit is contained in:
nolash 2021-04-13 17:37:12 +02:00
parent 6febf32bb7
commit c067c031a2
Signed by untrusted user who does not match committer: lash
GPG Key ID: 21D2E7BB88C2A746
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/cic-eth/requirements.txt
View File

@ -2,7 +2,7 @@ cic-base~=0.1.2a67
celery==4.4.7 celery==4.4.7
crypto-dev-signer~=0.4.14a17 crypto-dev-signer~=0.4.14a17
confini~=0.3.6rc3 confini~=0.3.6rc3
cic-eth-registry~=0.5.4a12 cic-eth-registry~=0.5.4a13
#cic-bancor~=0.0.6 #cic-bancor~=0.0.6
redis==3.5.3 redis==3.5.3
alembic==1.4.2 alembic==1.4.2

6
apps/contract-migration/scripts/cic_eth/import_balance.py
View File

@ -204,8 +204,8 @@ class Handler:
# return b # return b
def progress_callback(block_number, tx_index, s): def progress_callback(block_number, tx_index):
sys.stdout.write(str(s).ljust(200) + "\n") sys.stdout.write(str(block_number).ljust(200) + "\n")
@ -299,7 +299,7 @@ def main():
f.close() f.close()
syncer_backend.set(block_offset, 0) syncer_backend.set(block_offset, 0)
syncer = HeadSyncer(syncer_backend, post_callback=progress_callback) syncer = HeadSyncer(syncer_backend, block_callback=progress_callback)
handler = Handler(conn, chain_spec, user_dir, balances, sarafu_token_address, signer, gas_oracle, nonce_oracle) handler = Handler(conn, chain_spec, user_dir, balances, sarafu_token_address, signer, gas_oracle, nonce_oracle)
syncer.add_filter(handler) syncer.add_filter(handler)
syncer.loop(1, conn) syncer.loop(1, conn)

6
apps/contract-migration/scripts/eth/import_balance.py
View File

@ -204,8 +204,8 @@ class Handler:
# return b # return b
def progress_callback(block_number, tx_index, s): def progress_callback(block_number, tx_index):
sys.stdout.write(str(s).ljust(200) + "\n") sys.stdout.write(str(block_number).ljust(200) + "\n")
@ -299,7 +299,7 @@ def main():
f.close() f.close()
syncer_backend.set(block_offset, 0) syncer_backend.set(block_offset, 0)
syncer = HeadSyncer(syncer_backend, post_callback=progress_callback) syncer = HeadSyncer(syncer_backend, block_callback=progress_callback)
handler = Handler(conn, chain_spec, user_dir, balances, sarafu_token_address, signer, gas_oracle, nonce_oracle) handler = Handler(conn, chain_spec, user_dir, balances, sarafu_token_address, signer, gas_oracle, nonce_oracle)
syncer.add_filter(handler) syncer.add_filter(handler)
syncer.loop(1, conn) syncer.loop(1, conn)