Skip to content

Commit a01c0b5

Browse files
committed
Fix mypy error
1 parent c59ed5a commit a01c0b5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,7 @@ def _to_partition_key(self, partition: Mapping[str, Any]) -> str:
225225
def _to_dict(self, partition_key: str) -> Mapping[str, Any]:
226226
return self._partition_serializer.to_partition(partition_key)
227227

228-
def _create_cursor(self, cursor_state: Any) -> DeclarativeCursor:
228+
def _create_cursor(self, cursor_state: Any) -> Cursor:
229229
cursor = self._cursor_factory.create(stream_state=cursor_state)
230230
return cursor
231231

0 commit comments

Comments
 (0)