Skip to content

Commit

Permalink
force passing args by keywords
Browse files Browse the repository at this point in the history
  • Loading branch information
cl0ete committed Oct 31, 2024
1 parent 36f9b2c commit 2d9b649
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion waypoint/services/nats_service.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ def __init__(self, jetstream: JetStreamContext):
self.js_context: JetStreamContext = jetstream

async def _subscribe(
self, group_id: str, wallet_id: str, topic: str, state: str, look_back: int
self, *, group_id: str, wallet_id: str, topic: str, state: str, look_back: int
) -> JetStreamContext.PullSubscription:
try:
logger.trace(
Expand Down Expand Up @@ -70,6 +70,7 @@ async def _subscribe(
@asynccontextmanager
async def process_events(
self,
*,
group_id: str,
wallet_id: str,
topic: str,
Expand Down

0 comments on commit 2d9b649

Please sign in to comment.