Fix Record Filter Validation in ConcurrentDeclarativeSource

Author: tolik0

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

@@ -16,6 +16,7 @@
 from airbyte_cdk.sources.declarative.concurrency_level import ConcurrencyLevel
 from airbyte_cdk.sources.declarative.declarative_stream import DeclarativeStream
 from airbyte_cdk.sources.declarative.extractors import RecordSelector
+from airbyte_cdk.sources.declarative.extractors.record_filter import ClientSideIncrementalRecordFilterDecorator
 from airbyte_cdk.sources.declarative.incremental.datetime_based_cursor import DatetimeBasedCursor
 from airbyte_cdk.sources.declarative.interpolation import InterpolatedString
 from airbyte_cdk.sources.declarative.manifest_declarative_source import ManifestDeclarativeSource
@@ -291,6 +292,7 @@ def _stream_supports_concurrent_partition_processing(
             if isinstance(record_selector, RecordSelector):
                 if (
                     record_selector.record_filter
+                    and not isinstance(record_selector.record_filter, ClientSideIncrementalRecordFilterDecorator)
                     and "stream_state" in record_selector.record_filter.condition
                 ):
                     self.logger.warning(