Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Experimental yaml input format #1842

Draft
wants to merge 2 commits into
base: main
Choose a base branch
from
Draft
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 31 additions & 0 deletions msprime/cli.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@

import msprime
from . import ancestry
from . import json_input
from . import mutations


Expand Down Expand Up @@ -1119,6 +1120,15 @@ def run_ancestry(args):
tree_sequence.dump(args.output)


def run_ancestry_yaml(args):
setup_logging(args)
kwargs = json_input.parse_ancestry_yaml(args.yaml_file)
if "num_replicates" in kwargs:
raise ValueError("num_replicates not supported currently")
tree_sequence = msprime.sim_ancestry(**kwargs)
tree_sequence.dump(args.output)


def get_msp_parser():
top_parser = argparse.ArgumentParser(
description="Command line interface for msprime.", epilog=msprime_citation_text
Expand All @@ -1130,6 +1140,7 @@ def get_msp_parser():
subparsers.required = True

add_ancestry_subcommand(subparsers)
add_ancestry_yaml_subcommand(subparsers)
add_mutate_subcommand(subparsers)
add_simulate_subcommand(subparsers)

Expand Down Expand Up @@ -1301,6 +1312,26 @@ def add_ancestry_subcommand(subparsers) -> None:
parser.set_defaults(runner=run_ancestry)


def add_ancestry_yaml_subcommand(subparsers) -> None:
parser = subparsers.add_parser(
"ancestry-yaml",
help=(
"Simulate an ancestral history based on yaml input "
"and as a tskit tree sequence."
),
)
parser.add_argument(
"-v",
"--verbosity",
action="count",
default=0,
help="Increase the verbosity. Use -v for INFO output and -vv for DEBUG",
)
parser.add_argument("yaml_file", type=argparse.FileType("r"))
add_output_argument(parser)
parser.set_defaults(runner=run_ancestry_yaml)


def msp_main(arg_list=None):
set_sigpipe_handler()
parser = get_msp_parser()
Expand Down
51 changes: 51 additions & 0 deletions msprime/json_input.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,51 @@
#
# Copyright (C) 2021 University of Oxford
#
# This file is part of msprime.
#
# msprime is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# msprime is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with msprime. If not, see <http://www.gnu.org/licenses/>.
#
"""
Define formats used for simulation input as JSON and related formats.
"""
from __future__ import annotations

import copy
import json

import demes
from ruamel.yaml import YAML

import msprime


def parse_ancestry_json(data):
data = copy.deepcopy(data)
if "start_time" in data or "end_time" in data:
raise ValueError(
"specifying time values not currently supported as too confusing"
)
if "demography" in data:
demes_dict = data["demography"]
# TODO nasty going back to JSON here - can we make a demes.fromdict()
# function to do this directly?
demes_model = demes.loads(json.dumps(demes_dict), format="json")
Comment on lines +48 to +50
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Aha! Thanks @grahamgower.

data["demography"] = msprime.Demography.from_demes(demes_model)
return data


def parse_ancestry_yaml(text):

yaml = YAML(typ="safe")
return parse_ancestry_json(yaml.load(text))