Skip to content

Commit

Permalink
update another test
Browse files Browse the repository at this point in the history
  • Loading branch information
lynnagara committed Oct 16, 2023
1 parent 4a498f1 commit 8e10c87
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions tests/backends/test_kafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@
import itertools
import os
import pickle
import time
import uuid
from contextlib import closing
from datetime import datetime
from pickle import PickleBuffer
from typing import Any, Iterator, Mapping, MutableSequence, Optional
from unittest import mock
Expand Down Expand Up @@ -195,7 +195,9 @@ def test_consumer_stream_processor_shutdown(self) -> None:


def test_commit_codec() -> None:
commit = Commit("group", Partition(Topic("topic"), 0), 0, datetime.now())
commit = Commit(
"group", Partition(Topic("topic"), 0), 0, time.time(), time.time() - 5
)
assert commit_codec.decode(commit_codec.encode(commit)) == commit


Expand Down

0 comments on commit 8e10c87

Please sign in to comment.