Skip to content

Commit

Permalink
Solve double processed P2P messages (#676)
Browse files Browse the repository at this point in the history
* Fix: Update p2p protocol to use the patched version of the p2p python client library and to avoid waiting 2 seconds everytime that the consumer fails.

* Fixed code quality issues

* Fix: Added version change preparing for the new release.
  • Loading branch information
nesitor authored Jan 11, 2025
1 parent d1f1a24 commit 3674028
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions deployment/samples/docker-compose/docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ volumes:
services:
pyaleph:
restart: always
image: alephim/pyaleph-node:0.5.7
image: alephim/pyaleph-node:0.5.9
command: --config /opt/pyaleph/config.yml --key-dir /opt/pyaleph/keys -v
volumes:
- ./config.yml:/opt/pyaleph/config.yml
Expand All @@ -30,7 +30,7 @@ services:

pyaleph-api:
restart: always
image: alephim/pyaleph-node:0.5.7
image: alephim/pyaleph-node:0.5.9
command: --config /opt/pyaleph/config.yml --key-dir /opt/pyaleph/keys -v
entrypoint: ["bash", "deployment/scripts/run_aleph_ccn_api.sh"]
ports:
Expand Down
2 changes: 1 addition & 1 deletion docs/conf.py
Original file line number Diff line number Diff line change
Expand Up @@ -293,5 +293,5 @@


rst_epilog = """
.. |pyaleph_version| replace:: 0.5.7
.. |pyaleph_version| replace:: 0.5.9
"""
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ dependencies = [
"alembic==1.12.1",
"aleph-message==0.6",
"aleph-nuls2==0.1",
"aleph-p2p-client @ git+https://github.com/aleph-im/p2p-service-client-python@2c04af39c566217f629fd89505ffc3270fba8676",
"aleph-p2p-client @ git+https://github.com/aleph-im/p2p-service-client-python@cbfebb871db94b2ca580e66104a67cd730c5020c",
"aleph-pytezos==3.13.4",
"asyncpg==0.30",
"base58>=1.0.3",
Expand Down
2 changes: 1 addition & 1 deletion src/aleph/services/p2p/protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -71,4 +71,4 @@ async def incoming_channel(
except Exception:
LOGGER.exception("Exception in pubsub, reconnecting.")

await asyncio.sleep(2)
await asyncio.sleep(0.1)

0 comments on commit 3674028

Please sign in to comment.