Update queue and syncer
This commit is contained in:
parent
e003cd31d5
commit
50660f24b7
@ -1,5 +1,5 @@
|
||||
# external imports
|
||||
from chainqueue.sql.query import get_tx
|
||||
from chainqueue.sql.query import get_otx
|
||||
|
||||
|
||||
class SessionIndex:
|
||||
@ -9,7 +9,7 @@ class SessionIndex:
|
||||
|
||||
|
||||
def add(self, chain_spec, tx_hash, session=None):
|
||||
tx = get_tx(chain_spec, tx_hash, session=session)
|
||||
tx = get_otx(chain_spec, tx_hash, session=session)
|
||||
session.execute("INSERT INTO session (otx_id, session) VALUES ({},'{}')".format(tx['otx_id'], self.id))
|
||||
session.flush()
|
||||
|
||||
|
@ -1,6 +1,6 @@
|
||||
chainlib>=0.0.9a3,<=0.1.0
|
||||
chainqueue>=0.0.4a5,<=0.0.4
|
||||
chainsyncer>=0.0.6a1,<=0.0.6
|
||||
chainqueue>=0.0.4a7,<=0.0.4
|
||||
chainsyncer>=0.0.6a3,<=0.0.6
|
||||
confini>=0.4.1a1,<0.5.0
|
||||
crypto-dev-signer>=0.4.15a1,<0.5.0
|
||||
pyxdg~=0.26
|
||||
|
Loading…
Reference in New Issue
Block a user