Merge branch 'move_daskclient_into_bulk_persistence' into 'master'
move localcluster and daskclient into app.bulk_persistence See merge request !465
No related branches found
No related tags found
Pipeline #100206 passed with warnings
Stage: build
Stage: containerize
Stage: scan
Stage: deploy
Stage: integration
Stage: publish
Showing
- app/bulk_persistence/__init__.py 2 additions, 0 deletionsapp/bulk_persistence/__init__.py
- app/bulk_persistence/dask/client.py 89 additions, 0 deletionsapp/bulk_persistence/dask/client.py
- app/bulk_persistence/dask/dask_bulk_storage.py 2 additions, 2 deletionsapp/bulk_persistence/dask/dask_bulk_storage.py
- app/bulk_persistence/dask/localcluster.py 77 additions, 0 deletionsapp/bulk_persistence/dask/localcluster.py
- app/utils.py 0 additions, 126 deletionsapp/utils.py
- app/wdms_app.py 1 addition, 1 deletionapp/wdms_app.py
- tests/unit/bulk_persistence/dask/__init__.py 0 additions, 0 deletionstests/unit/bulk_persistence/dask/__init__.py
- tests/unit/bulk_persistence/dask/localcluster_test.py 51 additions, 0 deletionstests/unit/bulk_persistence/dask/localcluster_test.py
- tests/unit/bulk_persistence/dask_data_ipc_test.py 16 additions, 20 deletionstests/unit/bulk_persistence/dask_data_ipc_test.py
- tests/unit/conftest.py 8 additions, 3 deletionstests/unit/conftest.py
- tests/unit/fixtures.py 17 additions, 7 deletionstests/unit/fixtures.py
- tests/unit/fixtures_pkg/__init__.py 1 addition, 0 deletionstests/unit/fixtures_pkg/__init__.py
- tests/unit/fixtures_pkg/dask_client.py 51 additions, 0 deletionstests/unit/fixtures_pkg/dask_client.py
- tests/unit/fixtures_pkg/dask_client_test.py 44 additions, 0 deletionstests/unit/fixtures_pkg/dask_client_test.py
- tests/unit/persistence/dask_blob_storage_test.py 445 additions, 479 deletionstests/unit/persistence/dask_blob_storage_test.py
Loading
Please register or sign in to comment