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