Skip to content

Commit f074945

Browse files
committed
Add suffix to idempotency key
1 parent 0bf8a55 commit f074945

File tree

1 file changed

+7
-1
lines changed
  • src/apify_client/clients/resource_clients

1 file changed

+7
-1
lines changed

src/apify_client/clients/resource_clients/run.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
from __future__ import annotations
22

33
import json
4+
import random
5+
import string
46
import time
57
from typing import Any
68

@@ -491,11 +493,15 @@ async def charge(
491493
if not event_name:
492494
raise ValueError('event_name is required for charging an event')
493495

496+
idempotency_key = idempotency_key or (
497+
f'{self.resource_id}-{event_name}-{int(time.time() * 1000)}-{''.join(random.choices(string.ascii_letters + string.digits, k=6))}'
498+
)
499+
494500
response = await self.http_client.call(
495501
url=self._url('charge'),
496502
method='POST',
497503
headers={
498-
'idempotency-key': idempotency_key or f'{self.resource_id}-{event_name}-{int(time.time() * 1000)}',
504+
'idempotency-key': idempotency_key,
499505
'content-type': 'application/json',
500506
},
501507
data=json.dumps(

0 commit comments

Comments
 (0)