[DOP-18571] Collect and log Spark metrics in various method calls
94.46% of diff hit (target 94.84%)
View this Pull Request on Codecov
94.46% of diff hit (target 94.84%)
Annotations
Check warning on line 33 in onetl/_metrics/extract.py
codecov / codecov/patch
onetl/_metrics/extract.py#L33
Added line #L33 was not covered by tests
Check warning on line 44 in onetl/_metrics/extract.py
codecov / codecov/patch
onetl/_metrics/extract.py#L44
Added line #L44 was not covered by tests
Check warning on line 67 in onetl/_metrics/listener/base.py
codecov / codecov/patch
onetl/_metrics/listener/base.py#L67
Added line #L67 was not covered by tests
Check warning on line 18 in onetl/_metrics/listener/execution.py
codecov / codecov/patch
onetl/_metrics/listener/execution.py#L18
Added line #L18 was not covered by tests
Check warning on line 41 in onetl/_metrics/listener/execution.py
codecov / codecov/patch
onetl/_metrics/listener/execution.py#L41
Added line #L41 was not covered by tests
Check warning on line 73 in onetl/_metrics/listener/execution.py
codecov / codecov/patch
onetl/_metrics/listener/execution.py#L72-L73
Added lines #L72 - L73 were not covered by tests
Check warning on line 19 in onetl/_metrics/listener/job.py
codecov / codecov/patch
onetl/_metrics/listener/job.py#L19
Added line #L19 was not covered by tests
Check warning on line 64 in onetl/_metrics/listener/job.py
codecov / codecov/patch
onetl/_metrics/listener/job.py#L63-L64
Added lines #L63 - L64 were not covered by tests
Check warning on line 106 in onetl/_metrics/listener/listener.py
codecov / codecov/patch
onetl/_metrics/listener/listener.py#L106
Added line #L106 was not covered by tests
Check warning on line 19 in onetl/_metrics/listener/stage.py
codecov / codecov/patch
onetl/_metrics/listener/stage.py#L19
Added line #L19 was not covered by tests
Check warning on line 49 in onetl/_metrics/listener/stage.py
codecov / codecov/patch
onetl/_metrics/listener/stage.py#L49
Added line #L49 was not covered by tests
Check warning on line 51 in onetl/_metrics/listener/stage.py
codecov / codecov/patch
onetl/_metrics/listener/stage.py#L51
Added line #L51 was not covered by tests
Check warning on line 17 in onetl/_metrics/listener/task.py
codecov / codecov/patch
onetl/_metrics/listener/task.py#L17
Added line #L17 was not covered by tests
Check warning on line 89 in onetl/_metrics/listener/task.py
codecov / codecov/patch
onetl/_metrics/listener/task.py#L89
Added line #L89 was not covered by tests
Check warning on line 225 in onetl/connection/db_connection/hive/connection.py
codecov / codecov/patch
onetl/connection/db_connection/hive/connection.py#L224-L225
Added lines #L224 - L225 were not covered by tests
Check warning on line 235 in onetl/connection/db_connection/hive/connection.py
codecov / codecov/patch
onetl/connection/db_connection/hive/connection.py#L234-L235
Added lines #L234 - L235 were not covered by tests
Check warning on line 271 in onetl/connection/db_connection/hive/connection.py
codecov / codecov/patch
onetl/connection/db_connection/hive/connection.py#L270-L271
Added lines #L270 - L271 were not covered by tests
Check warning on line 281 in onetl/connection/db_connection/hive/connection.py
codecov / codecov/patch
onetl/connection/db_connection/hive/connection.py#L280-L281
Added lines #L280 - L281 were not covered by tests
Check warning on line 227 in onetl/db/db_writer/db_writer.py
codecov / codecov/patch
onetl/db/db_writer/db_writer.py#L227
Added line #L227 was not covered by tests
Check warning on line 149 in onetl/file/file_df_writer/file_df_writer.py
codecov / codecov/patch
onetl/file/file_df_writer/file_df_writer.py#L149
Added line #L149 was not covered by tests