Skip to content

Commit

Permalink
refactor: removed unused options (#578)
Browse files Browse the repository at this point in the history
* extra_payload
* str_enable

Are not used anywhere in the tests
  • Loading branch information
mkanoor authored Sep 12, 2023
1 parent 1e712fe commit 0fed02b
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions tests/sources/range.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,9 @@

async def main(queue: asyncio.Queue, args: Dict[str, Any]):
delay = args.get("delay", 0)
str_enable = args.get("str_enable", False)
extra_payload = args.get("extra_payload", None)

for i in range(int(args["limit"])):
payload = {"i": f"{i}"} if str_enable else {"i": i}
if extra_payload:
payload.update({"extra_payload": extra_payload})
payload = {"i": i}
await queue.put(payload)
await asyncio.sleep(delay)

Expand Down

0 comments on commit 0fed02b

Please sign in to comment.