Add new file service ingestion flow.
Showing
- src/dags/libs/constants.py 19 additions, 0 deletionssrc/dags/libs/constants.py
- src/dags/libs/exceptions.py 20 additions, 0 deletionssrc/dags/libs/exceptions.py
- src/dags/libs/handle_file.py 296 additions, 0 deletionssrc/dags/libs/handle_file.py
- src/dags/libs/process_manifest_r3.py 81 additions, 40 deletionssrc/dags/libs/process_manifest_r3.py
- src/dags/libs/source_file_check.py 20 additions, 8 deletionssrc/dags/libs/source_file_check.py
- src/plugins/operators/process_manifest_r3.py 3 additions, 4 deletionssrc/plugins/operators/process_manifest_r3.py
- tests/plugin-unit-tests/data/workProduct/SeismicTraceData.json 1 addition, 0 deletions.../plugin-unit-tests/data/workProduct/SeismicTraceData.json
- tests/plugin-unit-tests/data/workProduct/record_SeismicTraceData.json 40 additions, 44 deletions...-unit-tests/data/workProduct/record_SeismicTraceData.json
- tests/plugin-unit-tests/test_file_handler.py 163 additions, 0 deletionstests/plugin-unit-tests/test_file_handler.py
- tests/plugin-unit-tests/test_file_upload.py 0 additions, 66 deletionstests/plugin-unit-tests/test_file_upload.py
- tests/plugin-unit-tests/test_manifest_processor_r3.py 20 additions, 8 deletionstests/plugin-unit-tests/test_manifest_processor_r3.py
- tests/plugin-unit-tests/test_operators_r3.py 2 additions, 2 deletionstests/plugin-unit-tests/test_operators_r3.py
- tests/unit_tests.sh 1 addition, 0 deletionstests/unit_tests.sh
Loading
Please register or sign in to comment