orca

Getting Started

  • Installation
    • Requirements
    • Installing from source
    • Configuration
    • Dependencies
  • Quick Start
    • Starting the Pipeline
      • 1. Start Celery Workers
      • 2. Monitor with Flower
    • Running Pipeline Scripts
      • Flagging and Averaging
      • Dynamic Spectrum Production
    • Basic Usage in Python
  • ORCA Usage Guide
    • Configuration and Environment activation
    • Table of Contents
    • Concatenation
    • Flagging
      • Obtain and flag bad antennas (by correlator number)
      • Flag using AOFlagger and a specified strategy
    • Model Generation
    • Delay Calibration
    • Bandpass Calibration
    • Change Phase Center
    • Imaging with WSClean
    • Peeling with TTCal
    • QA Plotting
      • Delay Calibration QA Plot
      • Bandpass Calibration QA Plot
      • Gain Calibration QA

Subband Pipeline

  • Subband Processing Pipeline — Architecture & File Reference
    • Overview
    • File Map
      • Submission & Orchestration
      • Processing Logic (no Celery decorators — pure functions, testable locally)
      • Science Extraction Modules (Phase 2, steps 7b A–D)
      • Phase 3 — Wideband Aggregation (post_process_science)
      • Configuration
      • Utilities & Wrappers
    • Node ↔ Subband ↔ Queue Mapping
    • Dynamic Scheduling Mode
      • How it works
      • Usage
      • Monitoring the Redis work queue
      • Static vs Dynamic comparison
    • Directory Layout
    • Imaging Steps
    • External Dependencies
    • How It Connects
    • Timing Instrumentation
      • Phase 1 tags (per MS)
      • Phase 2 tags (per subband)
      • Phase 3 tags (wideband, post-run)
    • CLI Examples
  • Worker Management Guide
    • Quick Reference
    • After Code Changes
    • Adding/Removing Nodes
    • Submitting Jobs
    • Monitoring
    • Troubleshooting
      • Useful debug commands
  • ORCA Celery Deployment Guide
    • Table of Contents
    • Installation
    • Cluster Architecture
      • Node Summary
    • Components Overview
      • Message Flow
      • Component Details
      • Queues
    • Configuration
      • User Configuration File
      • Shared Environment
    • Managing Workers
      • Starting Workers
      • Stopping Workers
      • Checking Worker Status
      • Code Updates
    • Monitoring
      • Flower Web UI
      • Command-Line Monitoring
      • Inspecting Tasks
    • Adding New Users
      • 1. RabbitMQ Setup
      • 2. User Configuration
      • 3. Environment Setup
      • 4. Verify Setup
    • Troubleshooting
      • Workers Not Responding
      • Import Errors on Worker Start
      • Tasks Stuck in Queue
      • Worker Memory Issues
      • Redis Full
    • Quick Reference
      • Key Files
      • Key Commands
      • Service Locations
    • Infrastructure Reference
      • RabbitMQ
      • Redis

API Reference

  • API Reference
    • orca
      • Submodules
        • orca.autoscaler
        • orca.celery
        • orca.configmanager
        • orca.flagging
        • orca.metadata
        • orca.resources
        • orca.tasks
        • orca.transform
        • orca.utils
        • orca.wrapper
orca
  • API Reference
  • orca
  • orca.transform
  • orca.transform.transient_search
  • View page source

orca.transform.transient_search

OVRO-LWA Transient Search Module.

Ported from ExoPipe/transient_search.py into the orca package for use with the Celery pipeline. All pipeline_config imports are replaced by orca.resources.subband_config.

Stokes V: Search each image directly (NO reference subtraction). Stokes I: Subtract deep from each 10min snapshot.

run_test() returns a list of detection dicts (with snr key) so the caller can sort, filter, and apply a quality gate.

Attributes

CONFIG_I

CONFIG_V

CUTOUT_SIZE

MAX_CUTOUTS

Functions

load_catalog(path)

Load a source catalog for cross-matching.

get_midpoint_time(header)

Get observation midpoint from FITS header.

create_static_masks(header_tgt, header_ref, wcs, ...)

Create horizon and A-team masks.

create_bright_source_mask(data_ref, wcs, ...)

Adaptive masking: mask where Flux_Ref > (Tier * Sigma_Search).

calculate_local_rms_map(data, mask, cfg)

Compute a local RMS map using boxcar MAD.

extract_peaks_flex(data, mask, threshold_sigma, ...)

Extract peaks above (or below) a sigma threshold.

filter_bilobed_artifacts(candidates, partners, cfg)

Remove candidates that have a matching opposite-sign partner.

run_test(ref_path, tgt_path, ref_i_path, catalog_path)

Main entry point for transient search.

Module Contents

orca.transform.transient_search.CONFIG_I[source]
orca.transform.transient_search.CONFIG_V[source]
orca.transform.transient_search.CUTOUT_SIZE[source]
orca.transform.transient_search.MAX_CUTOUTS = 5[source]
orca.transform.transient_search.load_catalog(path)[source]

Load a source catalog for cross-matching.

orca.transform.transient_search.get_midpoint_time(header)[source]

Get observation midpoint from FITS header.

orca.transform.transient_search.create_static_masks(header_tgt, header_ref, wcs, shape, cfg)[source]

Create horizon and A-team masks.

orca.transform.transient_search.create_bright_source_mask(data_ref, wcs, header_for_beam, cfg, search_rms)[source]

Adaptive masking: mask where Flux_Ref > (Tier * Sigma_Search).

orca.transform.transient_search.calculate_local_rms_map(data, mask, cfg)[source]

Compute a local RMS map using boxcar MAD.

orca.transform.transient_search.extract_peaks_flex(data, mask, threshold_sigma, rms_map, wcs, obs_time)[source]

Extract peaks above (or below) a sigma threshold.

orca.transform.transient_search.filter_bilobed_artifacts(candidates, partners, cfg)[source]

Remove candidates that have a matching opposite-sign partner.

orca.transform.transient_search.run_test(ref_path, tgt_path, ref_i_path, catalog_path, output_dir=None, mode=None)[source]

Main entry point for transient search.

Parameters:
  • ref_path – Reference image for subtraction (1hr I deep). None for Stokes V.

  • tgt_path – Target image to search (10min snapshot or deep V).

  • ref_i_path – Reference Stokes I image for bright-source masking.

  • catalog_path – Path to source catalog CSV.

  • output_dir – Directory for cutouts and debug FITS.

  • mode – Force ‘V’ or ‘I’ mode. If None, auto-detected from path.

Returns:

List of detection dicts sorted by descending |SNR|.

Previous Next

© Copyright 2026, Caltech OVRO-LWA Team.

Built with Sphinx using a theme provided by Read the Docs.