Skip to content

Conversation

@dolfinus
Copy link
Member

@dolfinus dolfinus commented Dec 27, 2025

Change Summary

Related issue number

Checklist

  • Commit message and PR title is comprehensive
  • Keep the change as small as possible
  • Unit and integration tests for the changes exist
  • Tests pass on CI and coverage does not decrease
  • Documentation reflects the changes where applicable
  • docs/changelog/next_release/<pull request or issue id>.<change type>.rst file added describing change
    (see CONTRIBUTING.rst for details.)
  • My PR is ready to review.

@dolfinus dolfinus self-assigned this Dec 27, 2025
@dolfinus dolfinus added the ci:skip-changelog Add this label to skip changelog file check label Dec 27, 2025
@dolfinus dolfinus force-pushed the feature/switch-to-ruff branch 2 times, most recently from 4040a7d to 21675ed Compare December 27, 2025 15:26
@github-actions
Copy link

github-actions bot commented Dec 27, 2025

Coverage

Coverage Report •
FileStmtsMissCoverMissing
onetl
   log.py1091685%68, 105–106, 108–109, 145–146, 148–150, 169–171, 385, 394, 401
onetl/_metrics/listener
   base.py37197%68
   execution.py67297%18, 41
   job.py55198%19
   listener.py84198%108
   stage.py43295%19, 48
onetl/_util
   spark.py88297%101, 197
   version.py44393%34, 163, 179
onetl/connection
   __init__.py21195%105
onetl/connection/db_connection/db_connection
   connection.py35294%49, 51
onetl/connection/db_connection/dialect_mixins
   support_hint_str.py12191%27
   support_hwm_expression_str.py12283%18, 22
onetl/connection/db_connection/greenplum
   connection.py2382390%260, 264–265, 502, 507–508, 510–511, 513, 518–519, 521, 525, 529–530, 532–533, 535, 540, 543–546
onetl/connection/db_connection/hive
   connection.py217498%187–190
onetl/connection/db_connection/iceberg
   connection.py2083483%306, 340–343, 499–501, 503–504, 506–508, 518, 520–521, 537–538, 540–543, 545–547, 549, 586–587, 592–594, 596, 598, 613
   dialect.py6183%26
onetl/connection/db_connection/iceberg/catalog
   rest.py23673%119, 124–125, 127–128, 130
onetl/connection/db_connection/iceberg/catalog/auth
   basic.py10190%48
   bearer.py9188%43
   oauth2_client_credentials.py19289%107, 124
onetl/connection/db_connection/iceberg/warehouse
   delegated.py18288%78, 83
   filesystem.py27485%101–102, 106, 115
   s3.py38586%104, 115, 145–146, 150
onetl/connection/db_connection/jdbc_connection
   connection.py168298%175, 242
onetl/connection/db_connection/jdbc_mixin
   connection.py178298%478, 499
onetl/connection/db_connection/kafka
   connection.py248299%543–544
   kafka_kerberos_auth.py72297%170–171
   kafka_scram_auth.py25196%94
onetl/connection/db_connection/mongodb
   connection.py216597%347–348, 361, 431, 482
onetl/connection/db_connection/oracle
   connection.py1671591%403–404, 406, 413–418, 420, 449, 451–452, 454–455
   dialect.py26292%60–61
onetl/connection/file_connection
   file_connection.py3151694%140–141, 314, 318, 328–329, 385, 389, 410–411, 438, 448, 515, 522, 531, 785
   ftp.py83396%108, 122, 129
   samba.py133397%173, 225–226
   sftp.py1251290%172–177, 179–182, 184, 208
onetl/connection/file_df_connection
   spark_file_df_connection.py97891%55–57, 92, 120, 178, 180, 188
onetl/connection/file_df_connection/spark_hdfs
   connection.py1278037%165, 169, 172, 175, 178, 210–212, 214–216, 253–256, 260, 262–263, 267–270, 272–276, 278, 282, 284–287, 289–292, 296, 298, 302–308, 310, 313–314, 316–319, 321–327, 329–330, 333–334, 337–338, 340–343, 345–347, 349–350, 354–356, 360, 363
onetl/connection/file_df_connection/spark_s3
   connection.py1628845%247–248, 250, 298, 302, 305, 308, 311, 345–347, 354–355, 366–367, 377–378, 382–383, 385–386, 390–392, 396, 398–402, 407, 409, 413–414, 419, 422, 429–432, 435, 441–444, 446–448, 450–451, 453–454, 456–457, 460–463, 465, 467–468, 487–490, 496–498, 506, 509, 511–513, 515–516, 519, 531–538, 540–541, 546, 551
onetl/core
   __init__.py14192%57
onetl/core/file_filter
   file_filter.py83297%110–111
onetl/db/db_reader
   db_reader.py2511195%334, 369–370, 376, 384, 635–636, 723, 727, 748–749
onetl/db/db_writer
   db_writer.py74790%113, 124–126, 128, 184, 206
onetl/file/file_df_reader
   file_df_reader.py101199%273
onetl/file/file_df_writer
   file_df_writer.py72297%152, 182
   options.py59296%222, 226
onetl/file/file_downloader
   file_downloader.py3231196%486–487, 504–506, 718, 731, 884–885, 926–927
onetl/file/file_mover
   file_mover.py188597%349–350, 364–366
onetl/file/file_uploader
   file_uploader.py226996%352–353, 366–368, 430, 436, 608–609
onetl/file/filter
   file_mtime.py42197%110
onetl/file/format
   avro.py128298%562–563
   xml.py116496%423–425, 430
onetl/file/limit
   total_files_size.py34197%86
onetl/hooks
   hook.py1031288%102, 133, 188, 194, 306, 314, 318, 323, 339–341, 371
   slot.py157199%124
onetl/hwm
   auto_hwm.py21195%34
onetl/hwm/store
   __init__.py16193%55
   yaml_hwm_store.py61690%179–180, 182–183, 210–211
onetl/impl
   generic_options.py85297%71, 81
   path_repr.py105199%81
   remote_path_stat.py17194%41
onetl/plugins
   import_plugins.py42197%20
onetl/strategy
   base_strategy.py42197%47
   batch_hwm_strategy.py85198%83
   hwm_strategy.py77396%135–136, 138
TOTAL946647295% 

@dolfinus dolfinus force-pushed the feature/switch-to-ruff branch 3 times, most recently from 3cf9014 to 3e8871c Compare December 27, 2025 15:44
@dolfinus dolfinus force-pushed the feature/switch-to-ruff branch from 3e8871c to 88a540b Compare December 27, 2025 17:11
@dolfinus dolfinus marked this pull request as ready for review December 27, 2025 17:26
@dolfinus dolfinus merged commit be2a58a into develop Dec 27, 2025
58 checks passed
@dolfinus dolfinus deleted the feature/switch-to-ruff branch December 27, 2025 17:26
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci:skip-changelog Add this label to skip changelog file check

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant