Skip to content

Commit 4ea2fe0

Browse files
style: fix ruff formatting
Co-Authored-By: unknown <>
1 parent 69fb898 commit 4ea2fe0

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -234,14 +234,20 @@ def __init__(
234234
initial_number_of_partitions_to_generate = self._LOWEST_SAFE_CONCURRENCY_LEVEL // 2
235235

236236
if concurrency_level_from_manifest:
237-
raw_default_concurrency = concurrency_level_from_manifest.get("default_concurrency", "N/A")
237+
raw_default_concurrency = concurrency_level_from_manifest.get(
238+
"default_concurrency", "N/A"
239+
)
238240
self.logger.info(
239241
"Concurrency configuration: concurrency_level=%d, initial_number_of_partitions_to_generate=%d, "
240242
"source=manifest (expression=%s), config=%s",
241243
concurrency_level,
242244
initial_number_of_partitions_to_generate,
243245
raw_default_concurrency,
244-
{k: v for k, v in (config or {}).items() if "worker" in k.lower() or "concurren" in k.lower()},
246+
{
247+
k: v
248+
for k, v in (config or {}).items()
249+
if "worker" in k.lower() or "concurren" in k.lower()
250+
},
245251
)
246252
else:
247253
self.logger.info(

0 commit comments

Comments
 (0)