When running a Hermes workflow the is A LOT of output info about each task running, succeeding and failing. It is very useful if we could handle this in the UI. The best visualization that I can think of(maybe too much work and isn't worth it) is a full integration with the tasks progress through luigi, then we could show exactly all the running tasks, which ones are waiting for their dependencies and which ones failed/succeeded. The user will be able to individually look at each task's logs. Portion of some logs output from Hermes:
INFO : project.py/__init__(255) Initializing with logger lagrang
INFO : project.py/__init__(264) Attempting to get default directory from the disk
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(347) Searching for demo as a name of kind Simulations
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(351) Searching for demo as a resource of kind Simulations.
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(355) Searching for demo as a workflow group of kind Simulations.
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(403) ... Found it as workflow group
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(347) Searching for demo as a name of kind Simulations
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(351) Searching for demo as a resource of kind Simulations.
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(355) Searching for demo as a workflow group of kind Simulations.
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(403) ... Found it as workflow group
INFO : hermesWorkflowToolkit.py/executeWorkflowFromDB(721) Processing demo_0000
INFO : hermesWorkflowToolkit.py/executeWorkflowFromDB(731) Building and executing the workflow demo_0000
INFO : hermesWorkflowToolkit.py/executeWorkflowFromDB(737) Writing the workflow and the executer python demo_0000
DEBUG: Checking if finalnode_xx_0() is complete
DEBUG: Checking if fvSchemes_0() is complete
DEBUG: Checking if makeSource_0() is complete
DEBUG: Checking if buildAllRun_0() is complete
DEBUG: Checking if KinematicCloudProperties_0() is complete
DEBUG: Checking if makeDispersionFlowField_0() is complete
DEBUG: Checking if physicalProperties_0() is complete
DEBUG: Checking if g_0() is complete
DEBUG: Checking if Parameters_0() is complete
DEBUG: Checking if DispersionFlowField_fvSchemes_0() is complete
DEBUG: Checking if momentumTransport_0() is complete
DEBUG: Checking if dispersionFlowWriter_0() is complete
DEBUG: Checking if Neutral2018Dict_0() is complete
DEBUG: Checking if dispersionWriter_0() is complete
DEBUG: Checking if makeDispersionCase_0() is complete
DEBUG: Checking if createDistanceFromWalls_0() is complete
DEBUG: Checking if ControlDict_0() is complete
INFO: Informed scheduler that task finalnode_xx_0__99914b932b has status PENDING
INFO: Informed scheduler that task ControlDict_0__99914b932b has status PENDING
INFO: Informed scheduler that task createDistanceFromWalls_0__99914b932b has status PENDING
INFO: Informed scheduler that task makeDispersionCase_0__99914b932b has status PENDING
INFO: Informed scheduler that task dispersionWriter_0__99914b932b has status PENDING
INFO: Informed scheduler that task Neutral2018Dict_0__99914b932b has status PENDING
INFO: Informed scheduler that task dispersionFlowWriter_0__99914b932b has status PENDING
INFO: Informed scheduler that task momentumTransport_0__99914b932b has status PENDING
INFO: Informed scheduler that task DispersionFlowField_fvSchemes_0__99914b932b has status PENDING
INFO: Informed scheduler that task Parameters_0__99914b932b has status PENDING
INFO: Informed scheduler that task g_0__99914b932b has status PENDING
INFO: Informed scheduler that task physicalProperties_0__99914b932b has status PENDING
INFO: Informed scheduler that task makeDispersionFlowField_0__99914b932b has status PENDING
INFO: Informed scheduler that task KinematicCloudProperties_0__99914b932b has status PENDING
INFO: Informed scheduler that task buildAllRun_0__99914b932b has status PENDING
INFO: Informed scheduler that task makeSource_0__99914b932b has status PENDING
INFO: Informed scheduler that task fvSchemes_0__99914b932b has status PENDING
INFO: Done scheduling tasks
INFO: Running Worker with 1 processes
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 17
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running physicalProperties_0()
[DEBUG-JT] Node type: openFOAM.constant.physicalProperties, Version: 1
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done physicalProperties_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task physicalProperties_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 16
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running g_0()
[DEBUG-JT] Node type: openFOAM.constant.g, Version: 1
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done g_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task g_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 15
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running KinematicCloudProperties_0()
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done KinematicCloudProperties_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task KinematicCloudProperties_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 14
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running momentumTransport_0()
[DEBUG-JT] Node type: openFOAM.constant.momentumTransport, Version: 1
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done momentumTransport_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task momentumTransport_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 13
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running Neutral2018Dict_0()
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done Neutral2018Dict_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task Neutral2018Dict_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 12
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running fvSchemes_0()
[DEBUG-JT] Node type: openFOAM.system.FvSchemes, Version: 1
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done fvSchemes_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task fvSchemes_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 11
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running Parameters_0()
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done Parameters_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task Parameters_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 10
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running buildAllRun_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Parameters_0.json
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done buildAllRun_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task buildAllRun_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 9
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running ControlDict_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Parameters_0.json
[DEBUG-JT] Node type: openFOAM.system.ControlDict, Version: 1
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done ControlDict_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task ControlDict_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 8
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running makeDispersionFlowField_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Parameters_0.json
DEBUG : hera-openFoam/<module>(518) Got Namespace(OriginalFlowField='flatUrban_0001', dispersionFlowName='Ustar_25cm_sec', dispersionFlowParams="{'originalFlow': {'time': {'temporalType': 'steadyState', 'timestep': 0}, 'linkMeshSymbolically': True}, 'dispersionFields': {'ustar': 0.25, 'Hmix': 300}}", dispersionDuration='300', projectName=None, overwrite=True, func=<function stochasticLagrangian_dispersionFlow_create at 0x7dcca2545800>) in the command line
DEBUG : hera-openFoam/<module>(522) Activating the function
DEBUG : CLI.py/stochasticLagrangian_dispersionFlow_create(230) ----- Start -----
DEBUG : CLI.py/stochasticLagrangian_dispersionFlow_create(231) arguments: Namespace(OriginalFlowField='flatUrban_0001', dispersionFlowName='Ustar_25cm_sec', dispersionFlowParams="{'originalFlow': {'time': {'temporalType': 'steadyState', 'timestep': 0}, 'linkMeshSymbolically': True}, 'dispersionFields': {'ustar': 0.25, 'Hmix': 300}}", dispersionDuration='300', projectName=None, overwrite=True, func=<function stochasticLagrangian_dispersionFlow_create at 0x7dcca2545800>)
INFO : CLI.py/stochasticLagrangian_dispersionFlow_create(234) Adding dispersion flow to project None. Overwriting? True
INFO : project.py/__init__(255) Initializing with logger lagrang
INFO : project.py/__init__(264) Attempting to get default directory from the disk
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {}
/raid/software/python/pyenv/jammy/math2604/lib/python3.11/site-packages/distributed/node.py:188: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 42543 instead
warnings.warn(
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {}
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {}
INFO : CLI.py/stochasticLagrangian_dispersionFlow_create(240) Createing dispersion flow (DFF) Ustar_25cm_sec for the flow flatUrban_0001
INFO : abstractLagrangianSolver.py/createDispersionFlowField(78) Creating dispersion flow field : flatUrban_0001
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(347) Searching for flatUrban_0001 as a name of kind Simulations
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {'workflowName': 'flatUrban_0001'}
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing flatUrban_0001
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(407) ... Found it as name
INFO : abstractLagrangianSolver.py/createDispersionFlowField(87) Found original flow: /raid/users/liora/Projects/2026/lagrang/flatUrban_0001. Group: flatUrban_0001_DFF, Name: flatUrban_0001_DFF_Ustar_25cm_sec
INFO : abstractLagrangianSolver.py/_detectParallelAndTimesteps(205) Found timesteps: [0.0]
INFO : abstractLagrangianSolver.py/createDispersionFlowField(96) Simulation type: steadyState. Time mapping (orig,dest): [('0', '0'), ('0', '300')]
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {'groupName': 'flatUrban_0001_DFF', 'flowParameters__flowFields__ustar': 0.25, 'flowParameters__flowFields__Hmix': 300, 'flowParameters__flowFields__distanceFromWalls': 0, 'flowParameters__dispersionDuration': 300, 'flowParameters__originalFlow__time__temporalType': 'steadyState', 'flowParameters__originalFlow__time__timestep': 0, 'flowParameters__originalFlow__linkMeshSymbolically': True, 'flowParameters__originalFlow__source': 'flatUrban_0001', 'flowParameters__originalFlow__baseFlowDirectory': '/raid/users/liora/Projects/2026/lagrang/flatUrban_0001', 'flowParameters__originalFlow__timeStep': 0.0, 'workflowName': 'flatUrban_0001_DFF_Ustar_25cm_sec'}
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing flatUrban_0001_DFF
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing 0.25
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing 300
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing 0
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing 300
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing steadyState
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing 0
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing True
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing flatUrban_0001
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing /raid/users/liora/Projects/2026/lagrang/flatUrban_0001
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing 0.0
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing flatUrban_0001_DFF_Ustar_25cm_sec
INFO : abstractLagrangianSolver.py/_checkAndRegisterDispersionInDB(279) Overwriting — deleting old document
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(313) Mapping 0 → 0
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(323) Writing field ustar = 0.25 at t=0
INFO : OFObjectHome.py/getEmptyFieldFromCase(418) ----- Start : hera.simulations.openFoam.preprocessOFObjects.OFObjectHome.OFObjectHome.getEmptyFieldFromCase
INFO : OFObject.py/__init__(116) ---------Start : hera.simulations.openFoam.preprocessOFObjects.OFField.OFField.init
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(323) Writing field Hmix = 300 at t=0
INFO : OFObjectHome.py/getEmptyFieldFromCase(418) ----- Start : hera.simulations.openFoam.preprocessOFObjects.OFObjectHome.OFObjectHome.getEmptyFieldFromCase
INFO : OFObject.py/__init__(116) ---------Start : hera.simulations.openFoam.preprocessOFObjects.OFField.OFField.init
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(323) Writing field distanceFromWalls = 0 at t=0
INFO : OFObjectHome.py/getEmptyFieldFromCase(418) ----- Start : hera.simulations.openFoam.preprocessOFObjects.OFObjectHome.OFObjectHome.getEmptyFieldFromCase
INFO : OFObject.py/__init__(116) ---------Start : hera.simulations.openFoam.preprocessOFObjects.OFField.OFField.init
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(313) Mapping 0 → 300
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(323) Writing field ustar = 0.25 at t=300
INFO : OFObjectHome.py/getEmptyFieldFromCase(418) ----- Start : hera.simulations.openFoam.preprocessOFObjects.OFObjectHome.OFObjectHome.getEmptyFieldFromCase
INFO : OFObject.py/__init__(116) ---------Start : hera.simulations.openFoam.preprocessOFObjects.OFField.OFField.init
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(323) Writing field Hmix = 300 at t=300
INFO : OFObjectHome.py/getEmptyFieldFromCase(418) ----- Start : hera.simulations.openFoam.preprocessOFObjects.OFObjectHome.OFObjectHome.getEmptyFieldFromCase
INFO : OFObject.py/__init__(116) ---------Start : hera.simulations.openFoam.preprocessOFObjects.OFField.OFField.init
INFO : abstractLagrangianSolver.py/_prepareDispersionDirectory(323) Writing field distanceFromWalls = 0 at t=300
INFO : OFObjectHome.py/getEmptyFieldFromCase(418) ----- Start : hera.simulations.openFoam.preprocessOFObjects.OFObjectHome.OFObjectHome.getEmptyFieldFromCase
INFO : OFObject.py/__init__(116) ---------Start : hera.simulations.openFoam.preprocessOFObjects.OFField.OFField.init
INFO : abstractLagrangianSolver.py/_finalizeDispersionInDB(380) Adding new dispersion flow to database
INFO : abstractLagrangianSolver.py/createDispersionFlowField(134) ... Done
DEBUG : CLI.py/stochasticLagrangian_dispersionFlow_create(257) ----- End -----
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done makeDispersionFlowField_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task makeDispersionFlowField_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 7
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running DispersionFlowField_fvSchemes_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/makeDispersionFlowField_0.json
[DEBUG-JT] Node type: openFOAM.system.FvSchemes, Version: 1
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done DispersionFlowField_fvSchemes_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task DispersionFlowField_fvSchemes_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 6
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running makeDispersionCase_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/makeDispersionFlowField_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Parameters_0.json
DEBUG : hera-openFoam/<module>(518) Got Namespace(dispersionName='demo_0000', dispersionFlowField='flatUrban_0001_DFF_Ustar_25cm_sec', overwrite=True, func=<function stochasticLagrangian_dispersion_create at 0x745e501e9940>) in the command line
DEBUG : hera-openFoam/<module>(522) Activating the function
DEBUG : CLI.py/stochasticLagrangian_dispersion_create(385) ----- Start -----
DEBUG : CLI.py/stochasticLagrangian_dispersion_create(386) Got arguments: Namespace(dispersionName='demo_0000', dispersionFlowField='flatUrban_0001_DFF_Ustar_25cm_sec', overwrite=True, func=<function stochasticLagrangian_dispersion_create at 0x745e501e9940>)
INFO : CLI.py/stochasticLagrangian_dispersion_create(395) Using project lagrang
INFO : project.py/__init__(255) Initializing with logger lagrang
INFO : project.py/__init__(264) Attempting to get default directory from the disk
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {}
/raid/software/python/pyenv/jammy/math2604/lib/python3.11/site-packages/distributed/node.py:188: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 33745 instead
warnings.warn(
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {}
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {}
INFO : CLI.py/stochasticLagrangian_dispersion_create(400) Creating dispersion case demo_0000
INFO : CLI.py/stochasticLagrangian_dispersion_create(403) Getting the dispersion flowField flatUrban_0001_DFF_Ustar_25cm_sec
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(347) Searching for flatUrban_0001_DFF_Ustar_25cm_sec as a name of kind Simulations
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing {'workflowName': 'flatUrban_0001_DFF_Ustar_25cm_sec'}
DEBUG : jsonutils.py/ConfigurationToJSON(72) dictionary, calling recursively
DEBUG : jsonutils.py/ConfigurationToJSON(68) Processing flatUrban_0001_DFF_Ustar_25cm_sec
INFO : hermesWorkflowToolkit.py/getWorkflowDocumentFromDB(407) ... Found it as name
INFO : CLI.py/stochasticLagrangian_dispersion_create(406) Dispersion flow flatUrban_0001_DFF_Ustar_25cm_sec not found in DB. Trying to use as a directory
INFO : CLI.py/stochasticLagrangian_dispersion_create(417) Dispersion demo_0000 exists.
INFO : CLI.py/stochasticLagrangian_dispersion_create(419) Got the overwrite flag: removing old directory
INFO : CLI.py/stochasticLagrangian_dispersion_create(426) Creating dispersion case demo_0000 and linking to /raid/users/liora/Projects/2026/lagrang/flatUrban_0001_DFF_Ustar_25cm_sec
INFO : abstractLagrangianSolver.py/createAndLinkDispersionCaseDirectory(595) Creating dispersion at /raid/users/liora/Projects/2026/lagrang/demo_0000 with base flow /raid/users/liora/Projects/2026/lagrang/flatUrban_0001_DFF_Ustar_25cm_sec
INFO : abstractLagrangianSolver.py/createAndLinkDispersionCaseDirectory(645) ... Done
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done makeDispersionCase_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task makeDispersionCase_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 5
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running dispersionFlowWriter_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/makeDispersionCase_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Parameters_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/DispersionFlowField_fvSchemes_0.json
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done dispersionFlowWriter_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task dispersionFlowWriter_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 4
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running dispersionWriter_0()
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/fvSchemes_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/KinematicCloudProperties_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/physicalProperties_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/g_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/momentumTransport_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Parameters_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/Neutral2018Dict_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/makeDispersionCase_0.json
Load /raid/users/liora/Projects/2026/lagrang/demo_0000_targetFiles/ControlDict_0.json
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) done dispersionWriter_0()
DEBUG: 1 running tasks, waiting for next task to finish
INFO: Informed scheduler that task dispersionWriter_0__99914b932b has status DONE
DEBUG: Asking scheduler for work...
DEBUG: Pending tasks: 3
INFO: [pid 1576123] Worker Worker(salt=4880973842, workers=1, host=int-math553, username=liora, pid=1576123) running makeSource_0()
When running a Hermes workflow the is A LOT of output info about each task running, succeeding and failing. It is very useful if we could handle this in the UI. The best visualization that I can think of(maybe too much work and isn't worth it) is a full integration with the tasks progress through luigi, then we could show exactly all the running tasks, which ones are waiting for their dependencies and which ones failed/succeeded. The user will be able to individually look at each task's logs. Portion of some logs output from Hermes: