subpulse/pipelines/cluster.py
def run(
    event: int,
    arrivals: list,
    chi: float,
    jobs: int,
    simulations: int,
) -> None:
    """Run the subpulse analysis on the CHIME/FRB Cluster."""
    click.echo("Running Subpulse TOA Analysis")
    click.echo(f"Parameters : {locals()}")
    fingerprint = int(time.time())
    click.echo(f"Fingerprint: {fingerprint}")

    master = frb_master.FRBMaster()
    click.echo(f"Backend: {master.version()}")

    for job in range(jobs):
        response = master.swarm.spawn_job(
            job_name=f"subpulse-toa-{event}-{job}",
            image_name="chimefrb/subpulse",
            command=["python"],
            arguments=[
                "/src/subpulse/pipelines/pipeline.py",
                "--event",
                f"{event}",
                "--arrivals",
                f"{arrivals}",
                "--chi",
                f"{chi}",
                "--simulations",
                f"{int(simulations/jobs)}",
                "--fingerprint",
                f"{fingerprint}",
                "--cluster",
                f"{True}",
                "--job",
                f"{job}",
            ],
            job_cpu_limit=1,
            job_cpu_reservation=1,
        )
Run the subpulse analysis on the CHIME/FRB Cluster.
Run the subpulse analysis on the CHIME/FRB Cluster.
Run the subpulse analysis on the CHIME / FRB Cluster .
def run(
    event: int,
    arrivals: list,
    chi: float,
    jobs: int,
    simulations: int,
) -> None:
    click.echo("Running Subpulse TOA Analysis")
    click.echo(f"Parameters : {locals()}")
    fingerprint = int(time.time())
    click.echo(f"Fingerprint: {fingerprint}")
    master = frb_master.FRBMaster()
    click.echo(f"Backend: {master.version()}")
    for job in range(jobs):
        response = master.swarm.spawn_job(
            job_name=f"subpulse-toa-{event}-{job}",
            image_name="chimefrb/subpulse",
            command=["python"],
            arguments=[
                "/src/subpulse/pipelines/pipeline.py",
                "--event",
                f"{event}",
                "--arrivals",
                f"{arrivals}",
                "--chi",
                f"{chi}",
                "--simulations",
                f"{int(simulations/jobs)}",
                "--fingerprint",
                f"{fingerprint}",
                "--cluster",
                f"{True}",
                "--job",
                f"{job}",
            ],
            job_cpu_limit=1,
            job_cpu_reservation=1,
        )
def run ( event : int , arrivals : list , chi : float , jobs : int , simulations : int , ) -> None : click . echo ( "Running Subpulse TOA Analysis" ) click . echo ( f"Parameters : {locals()}" ) fingerprint = int ( time . time ( ) ) click . echo ( f"Fingerprint: {fingerprint}" ) master = frb_master . FRBMaster ( ) click . echo ( f"Backend: {master.version()}" ) for job in range ( jobs ) : response = master . swarm . spawn_job ( job_name = f"subpulse-toa-{event}-{job}" , image_name = "chimefrb/subpulse" , command = [ "python" ] , arguments = [ "/src/subpulse/pipelines/pipeline.py" , "--event" , f"{event}" , "--arrivals" , f"{arrivals}" , "--chi" , f"{chi}" , "--simulations" , f"{int(simulations/jobs)}" , "--fingerprint" , f"{fingerprint}" , "--cluster" , f"{True}" , "--job" , f"{job}" , ] , job_cpu_limit = 1 , job_cpu_reservation = 1 , )
Run the subpulse analysis on the CHIME/FRB Cluster.
Run the subpulse analysis on the CHIME / FRB Cluster .
"""Run the subpulse analysis on the CHIME/FRB Cluster."""
event
int
arrivals
list
chi
float
jobs
int
simulations
int