Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
ptpaterson committed Oct 10, 2024
1 parent 62d4c9c commit 6c6a405
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
2 changes: 2 additions & 0 deletions tests/integration/test_change_feeds.py
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,7 @@ def test_change_feed_cursor(client, a_collection):
nums = [event['data'] for event in feed.flatten()]
assert nums == list(range(1, 64))


def test_rejects_when_both_start_ts_and_cursor_provided(scoped_client):
scoped_client.query(fql("Collection.create({name: 'Product'})"))

Expand All @@ -124,6 +125,7 @@ def test_rejects_when_both_start_ts_and_cursor_provided(scoped_client):
opts = ChangeFeedOptions(cursor="abc1234==", start_ts=response.txn_ts)
scoped_client.change_feed(stream_token, opts)


def test_change_feed_reusable_iterator(client, a_collection):
feed = client.change_feed(
fql("${col}.all().map(.n).toStream()", col=a_collection))
Expand Down
2 changes: 2 additions & 0 deletions tests/integration/test_stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -228,6 +228,7 @@ def test_rejects_cursor_with_fql_query(scoped_client):
opts = StreamOptions(cursor="abc1234==")
scoped_client.stream(fql("Collection.create({name: 'Product'})"), opts)


def test_rejects_when_both_start_ts_and_cursor_provided(scoped_client):
scoped_client.query(fql("Collection.create({name: 'Product'})"))

Expand All @@ -238,6 +239,7 @@ def test_rejects_when_both_start_ts_and_cursor_provided(scoped_client):
opts = StreamOptions(cursor="abc1234==", start_ts=response.txn_ts)
scoped_client.stream(stream_token, opts)


def test_handle_status_events(scoped_client):
scoped_client.query(fql("Collection.create({name: 'Product'})"))

Expand Down

0 comments on commit 6c6a405

Please sign in to comment.