Skip to content

Commit 3ea1674

Browse files
committed
file-mode-api: run ruff format
1 parent e860e3f commit 3ea1674

File tree

4 files changed

+8
-2
lines changed

4 files changed

+8
-2
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3617,7 +3617,9 @@ def create_file_uploader(
36173617
requester=requester,
36183618
download_target_extractor=download_target_extractor,
36193619
config=config,
3620-
file_writer=NoopFileWriter() if emit_connector_builder_messages else LocalFileSystemFileWriter(),
3620+
file_writer=NoopFileWriter()
3621+
if emit_connector_builder_messages
3622+
else LocalFileSystemFileWriter(),
36213623
parameters=model.parameters or {},
36223624
filename_extractor=model.filename_extractor if model.filename_extractor else None,
36233625
)

airbyte_cdk/sources/declarative/retrievers/file_uploader/default_file_uploader.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,9 @@ def upload(self, record: Record) -> None:
7272
)
7373

7474
if self.content_extractor:
75-
raise NotImplementedError("Content extraction is not yet implemented. The content_extractor component is currently not supported.")
75+
raise NotImplementedError(
76+
"Content extraction is not yet implemented. The content_extractor component is currently not supported."
77+
)
7678
else:
7779
files_directory = Path(get_files_directory())
7880

airbyte_cdk/sources/declarative/retrievers/file_uploader/noop_file_writer.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
class NoopFileWriter(FileWriter):
1111
NOOP_FILE_SIZE = -1
12+
1213
def write(self, file_path: Path, content: bytes) -> int:
1314
"""
1415
Noop file writer

unit_tests/sources/declarative/file/test_file_stream.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
from airbyte_cdk.test.state_builder import StateBuilder
1717
from airbyte_cdk.sources.declarative.retrievers.file_uploader.noop_file_writer import NoopFileWriter
1818

19+
1920
class ConfigBuilder:
2021
def build(self) -> Dict[str, Any]:
2122
return {

0 commit comments

Comments
 (0)