kkonganti@11: #!/usr/bin/env python
kkonganti@11:
kkonganti@11: import yaml
kkonganti@11: import platform
kkonganti@11: import subprocess
kkonganti@11: from textwrap import dedent
kkonganti@11:
kkonganti@11:
kkonganti@11: def _make_versions_html(versions):
kkonganti@11: html = [
kkonganti@11: dedent(
kkonganti@11: """\\
kkonganti@11:
kkonganti@11:
kkonganti@11:
kkonganti@11:
kkonganti@11:
kkonganti@11:
kkonganti@11:
kkonganti@11:
kkonganti@11: Process Name |
kkonganti@11: Software |
kkonganti@11: Version |
kkonganti@11:
kkonganti@11:
kkonganti@11: """
kkonganti@11: )
kkonganti@11: ]
kkonganti@11: for process, tmp_versions in sorted(versions.items()):
kkonganti@11: html.append("")
kkonganti@11: for i, (tool, version) in enumerate(sorted(tmp_versions.items())):
kkonganti@11: html.append(
kkonganti@11: dedent(
kkonganti@11: f"""\\
kkonganti@11:
kkonganti@11: {process if (i == 0) else ''} |
kkonganti@11: {tool} |
kkonganti@11: {version} |
kkonganti@11:
kkonganti@11: """
kkonganti@11: )
kkonganti@11: )
kkonganti@11: html.append("")
kkonganti@11: html.append("
")
kkonganti@11: return "\\n".join(html)
kkonganti@11:
kkonganti@11:
kkonganti@11: versions_this_module = {}
kkonganti@11: versions_this_module["${task.process}"] = {
kkonganti@11: "python": platform.python_version(),
kkonganti@11: "yaml": yaml.__version__,
kkonganti@11: }
kkonganti@11:
kkonganti@11: with open("$versions") as f:
kkonganti@11: versions_by_process = yaml.load(f, Loader=yaml.BaseLoader)
kkonganti@11: versions_by_process.update(versions_this_module)
kkonganti@11:
kkonganti@11: # aggregate versions by the module name (derived from fully-qualified process name)
kkonganti@11: versions_by_module = {}
kkonganti@11: for process, process_versions in versions_by_process.items():
kkonganti@11: module = process.split(":")[-1]
kkonganti@11: try:
kkonganti@11: assert versions_by_module[module] == process_versions, (
kkonganti@11: "We assume that software versions are the same between all modules. "
kkonganti@11: "If you see this error-message it means you discovered an edge-case "
kkonganti@11: "and should open an issue in nf-core/tools. "
kkonganti@11: )
kkonganti@11: except KeyError:
kkonganti@11: versions_by_module[module] = process_versions
kkonganti@11:
kkonganti@11: versions_by_module["CPIPES"] = {
kkonganti@11: "Nextflow": "$workflow.nextflow.version",
kkonganti@11: "$workflow.manifest.name": "$workflow.manifest.version",
kkonganti@11: "${params.pipeline}": "${params.workflow_version}",
kkonganti@11: }
kkonganti@11:
kkonganti@11: versions_mqc = {
kkonganti@11: "id": "software_versions",
kkonganti@11: "section_name": "${workflow.manifest.name} Software Versions",
kkonganti@11: "section_href": "https://github.com/CFSAN-Biostatistics/bettercallsal",
kkonganti@11: "plot_type": "html",
kkonganti@11: "description": "Collected at run time from the software output (STDOUT/STDERR).",
kkonganti@11: "data": _make_versions_html(versions_by_module),
kkonganti@11: }
kkonganti@11:
kkonganti@11: with open("software_versions.yml", "w") as f:
kkonganti@11: yaml.dump(versions_by_module, f, default_flow_style=False)
kkonganti@11:
kkonganti@11: # print('sed -i -e "' + "s%'%%g" + '" *.yml')
kkonganti@11: subprocess.run('sed -i -e "' + "s%'%%g" + '" software_versions.yml', shell=True)
kkonganti@11:
kkonganti@11: with open("software_versions_mqc.yml", "w") as f:
kkonganti@11: yaml.dump(versions_mqc, f, default_flow_style=False)
kkonganti@11:
kkonganti@11: with open("versions.yml", "w") as f:
kkonganti@11: yaml.dump(versions_this_module, f, default_flow_style=False)