airbyte_cdk.sources.concurrent_source.partition_generation_completed_sentinel 

 1#
 2# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 3#
 4from typing import Any
 5
 6from airbyte_cdk.sources.streams.concurrent.abstract_stream import AbstractStream
 7
 8
 9class PartitionGenerationCompletedSentinel:
10    """
11    A sentinel object indicating all partitions for a stream were produced.
12    Includes a pointer to the stream that was processed.
13    """
14
15    def __init__(self, stream: AbstractStream):
16        """
17        :param stream: The stream that was processed
18        """
19        self.stream = stream
20
21    def __eq__(self, other: Any) -> bool:
22        if isinstance(other, PartitionGenerationCompletedSentinel):
23            return self.stream == other.stream
24        return False
class PartitionGenerationCompletedSentinel: 
10class PartitionGenerationCompletedSentinel:
11    """
12    A sentinel object indicating all partitions for a stream were produced.
13    Includes a pointer to the stream that was processed.
14    """
15
16    def __init__(self, stream: AbstractStream):
17        """
18        :param stream: The stream that was processed
19        """
20        self.stream = stream
21
22    def __eq__(self, other: Any) -> bool:
23        if isinstance(other, PartitionGenerationCompletedSentinel):
24            return self.stream == other.stream
25        return False

A sentinel object indicating all partitions for a stream were produced. Includes a pointer to the stream that was processed.

PartitionGenerationCompletedSentinel( stream: airbyte_cdk.sources.streams.concurrent.abstract_stream.AbstractStream) 
16    def __init__(self, stream: AbstractStream):
17        """
18        :param stream: The stream that was processed
19        """
20        self.stream = stream
Parameters
  • stream: The stream that was processed
stream