Pipeline

• 

  Rui Xue <rx.astro@gmail.com> 3 hours ago 4b16dca15cc621ad3032ca191aa295752f5dc025

  PIPE-3073: Improve Dask worker logging and fix distributed environment issues
  Enhance logging tracing with `DASK_WORKER_ID`, isolate D-Bus to prevent
  deadlocks, fix tar member handling, and update logging consistency across
  Prefect adapter and infrastructure modules.

  • pipeline/config.yaml (version 4b16dca15cc621ad3032ca191aa295752f5dc025) (diffs)
  • pipeline/h/tasks/exportdata/exportdata.py (version 4b16dca15cc621ad3032ca191aa295752f5dc025) (diffs)
  • pipeline/infrastructure/daskhelpers.py (version 4b16dca15cc621ad3032ca191aa295752f5dc025) (diffs)
  • pipeline/infrastructure/logging.py (version 4b16dca15cc621ad3032ca191aa295752f5dc025) (diffs)
  • pipeline/infrastructure/prefect_adapter.py (version 4b16dca15cc621ad3032ca191aa295752f5dc025) (diffs)
• 

  Rui Xue <rx.astro@gmail.com> 4 hours ago c99c1833c7c6d070f2b270ca65c06ba7fc2b4e6d

  PIPE-3072: Refactor type hints in `find_executable` and update error handling in `pclean`. Remove unnecessary MPI marker from test classes.

  • pipeline/infrastructure/utils/pclean.py (version c99c1833c7c6d070f2b270ca65c06ba7fc2b4e6d) (diffs)
  • pipeline/infrastructure/utils/pclean_test.py (version c99c1833c7c6d070f2b270ca65c06ba7fc2b4e6d) (diffs)
• 

  Rui Xue <rx.astro@gmail.com> 4 hours ago fa9b78cfe0669a09ea93ec57499308896b7299fa

  PIPE-3073: Add missing import for `unix_seconds_to_datetime` in `conversion_test.py` that was lost during the last conflict resolution.

  • pipeline/infrastructure/utils/conversion_test.py (version fa9b78cfe0669a09ea93ec57499308896b7299fa) (diffs)