diff --git a/caper/cromwell_workflow_monitor.py b/caper/cromwell_workflow_monitor.py index ed21585..de5fd15 100644 --- a/caper/cromwell_workflow_monitor.py +++ b/caper/cromwell_workflow_monitor.py @@ -296,6 +296,13 @@ def _update_metadata(self, workflow_id): """ if not self._is_server or not self._auto_update_metadata: return + if workflow_id in self._subworkflows and self._embed_subworkflow: + logger.debug( + 'Skipped writing metadata JSON file of subworkflow {wf_id}'.format( + wf_id=workflow_id + ) + ) + return for trial in range(CromwellWorkflowMonitor.MAX_RETRY_UPDATE_METADATA + 1): try: time.sleep(CromwellWorkflowMonitor.INTERVAL_RETRY_UPDATE_METADATA)