Support Iceberg in read_from/write_from JobSocket

[george-zubrienko]

No description provided.

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
bootstrap-lk.py	13	10	23%	6–46, 50
spark_utils/common
functions.py	35	3	91%	56, 62, 117
spark_job_args.py	68	9	87%	106, 113, 135, 151, 170, 179–183
spark_session_provider.py	83	24	71%	60–61, 110, 128, 155, 171, 190–201, 211–281, 294, 310
spark_sql_utils.py	20	10	50%	54–63, 79–82
spark_udf.py	4	2	50%	36–37
spark_utils/dataframes
functions.py	98	48	51%	48, 55–65, 76–78, 93–95, 108–122, 141, 151, 191, 199–202, 211, 230, 246–250, 259–272
spark_utils/dataframes/sets
functions.py	6	4	33%	39–42
spark_utils/delta_lake
delta_log.py	17	1	94%	52
functions.py	60	38	37%	57–67, 97–127, 140–160, 196–197, 200, 220–223
spark_utils/models
iceberg_rest_config.py	21	3	86%	51–53
k8s_config.py	18	2	89%	18–19
test
test_iceberg.py	23	4	83%	12–13, 23–24
test_spark_session_provider.py	24	6	75%	11–12, 24–25, 35–36
TOTAL	704	164	77%

Tests	Skipped	Failures	Errors	Time
60	0 💤	0 ❌	0 🔥	1m 36s ⏱️