Unverified Commit 5684562f authored by mvdbeek's avatar mvdbeek
Browse files

Send reload message after data bundle import is complete

parent 9a595469

lib/galaxy/celery/tasks.py

+3 −0
Original line number Diff line number Diff line
@@ -34,6 +34,7 @@ from galaxy.managers.model_stores import ModelStoreManager 
from galaxy.managers.tool_data import ToolDataImportManager

from galaxy.metadata.set_metadata import set_metadata_portable

from galaxy.model.scoped_session import galaxy_scoped_session

from galaxy.queue_worker import GalaxyQueueWorker

from galaxy.schema.tasks import (

    ComputeDatasetHashTaskRequest,

    GenerateHistoryContentDownload,
@@ -396,6 +397,8 @@ def import_data_bundle( 
        else:

            dataset = ldda_manager.by_id(id)

        tool_data_import_manager.import_data_bundle_by_dataset(config, dataset, tool_data_file_path=tool_data_file_path)

    queue_worker = GalaxyQueueWorker(app)

    queue_worker.send_control_task("reload_tool_data_tables")





@galaxy_task(action="pruning history audit table")

test/integration/test_tool_data_delete.py

+2 −0
Original line number Diff line number Diff line
@@ -45,6 +45,8 @@ class DataManagerIntegrationTestCase(integration_util.IntegrationTestCase): 
        return show_response.json()["fields"]



    def _testbeta_field_count(self) -> int:

        # We need to wait for the reload message to reach the control message consumer

        time.sleep(1)

        return len(self._testbase_fields())