ingest.triggers package

Submodules

ingest.triggers.ingest_recipe_handler module

Defines the class that handles ingest trigger rules

class ingest.triggers.ingest_recipe_handler.IngestRecipeHandler

Bases: object

Handles ingest trigger rules

process_ingested_source_file(ingest_id, source, source_file, when)

Processes the given ingested source file by kicking off its recipe. All database changes are made in an atomic transaction.

Parameters:
  • source – The strike that triggered the ingest
  • source_file (source.models.SourceFile) – The source file that was ingested
  • when (datetime.datetime) – When the source file was ingested
process_ingested_source_file_cm(ingest_id, source, source_file, when)

Processes the given ingested source file by kicking off its recipe. All database changes are made in an atomic transaction.

Parameters:
  • source – The strike that triggered the ingest
  • source_file (source.models.SourceFile) – The source file that was ingested
  • when (datetime.datetime) – When the source file was ingested
process_manual_ingested_source_file(ingest_id, source_file, when, recipe_type_id)

Processes a manual ingest where a strike or scan is not involved. All database changes are made in an atomic transaction

Parameters:
  • ingest_id (int) –
  • source_file (source.models.SourceFile) – The source file that was ingested
  • when (datetime.datetime) – When the source file was ingested
  • recipe_type_id (int) – id of the Recipe type to kick off

Module contents

Triggers (see trigger app) related to ingest