We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7a0e9f6 commit e2c3b80Copy full SHA for e2c3b80
test/sasl/test_msk.py
@@ -1,5 +1,6 @@
1
import datetime
2
import json
3
+import sys
4
5
from kafka.sasl.msk import AwsMskIamClient
6
@@ -10,7 +11,10 @@
10
11
12
13
def client_factory(token=None):
- now = datetime.datetime.utcfromtimestamp(1629321911)
14
+ if sys.version_info >= (3, 3):
15
+ now = datetime.datetime.fromtimestamp(1629321911, datetime.timezone.utc)
16
+ else:
17
+ now = datetime.datetime.utcfromtimestamp(1629321911)
18
with mock.patch('kafka.sasl.msk.datetime') as mock_dt:
19
mock_dt.datetime.utcnow = mock.Mock(return_value=now)
20
return AwsMskIamClient(
0 commit comments