Skip to content

Commit e00e10c

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent 806cdff commit e00e10c

File tree

3 files changed

+12
-6
lines changed

3 files changed

+12
-6
lines changed

airbyte_cdk/sources/file_based/exceptions.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,4 +160,4 @@ class FileSizeLimitError(CustomFileBasedException):
160160

161161

162162
class EmptyFileSchemaInferenceError(AirbyteTracedException):
163-
pass
163+
pass

airbyte_cdk/sources/file_based/file_types/csv_parser.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,11 @@
2222
InferenceType,
2323
)
2424
from airbyte_cdk.sources.file_based.config.file_based_stream_config import FileBasedStreamConfig
25-
from airbyte_cdk.sources.file_based.exceptions import FileBasedSourceError, RecordParseError, \
26-
EmptyFileSchemaInferenceError
25+
from airbyte_cdk.sources.file_based.exceptions import (
26+
EmptyFileSchemaInferenceError,
27+
FileBasedSourceError,
28+
RecordParseError,
29+
)
2730
from airbyte_cdk.sources.file_based.file_based_stream_reader import (
2831
AbstractFileBasedStreamReader,
2932
FileReadMode,

airbyte_cdk/sources/file_based/stream/default_file_based_stream.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,13 @@
1616
from airbyte_cdk.sources.file_based.config.file_based_stream_config import PrimaryKeyType
1717
from airbyte_cdk.sources.file_based.exceptions import (
1818
DuplicatedFilesError,
19+
EmptyFileSchemaInferenceError,
1920
FileBasedSourceError,
2021
InvalidSchemaError,
2122
MissingSchemaError,
2223
RecordParseError,
2324
SchemaInferenceError,
24-
StopSyncPerValidationPolicy, EmptyFileSchemaInferenceError,
25+
StopSyncPerValidationPolicy,
2526
)
2627
from airbyte_cdk.sources.file_based.file_types import FileTransfer
2728
from airbyte_cdk.sources.file_based.remote_file import RemoteFile
@@ -392,10 +393,12 @@ async def _infer_file_schema(self, file: RemoteFile) -> SchemaType:
392393
except Exception as exc:
393394
self._raise_schema_inference_error(exc, file)
394395

395-
def _raise_schema_inference_error(self, exc: Exception, file: Optional[RemoteFile] = None) -> None:
396+
def _raise_schema_inference_error(
397+
self, exc: Exception, file: Optional[RemoteFile] = None
398+
) -> None:
396399
raise SchemaInferenceError(
397400
FileBasedSourceError.SCHEMA_INFERENCE_ERROR,
398401
file=file.uri if file else None,
399402
format=str(self.config.format) if self.config.format else None,
400403
stream=self.name,
401-
) from exc
404+
) from exc

0 commit comments

Comments
 (0)