NYSETL.Engines.E5.Broadway behaviour (nys_etl v0.1.0) View Source

Fetches newly updated patient_cases from all counties in CommCare, and updates or creates IndexCases as needed.

Link to this section Summary

Link to this section Callbacks

Link to this callback

process_name(name, base_name)

View Source

Specs

process_name(Broadway.name(), base_name :: String.t()) :: Broadway.name()

Link to this section Functions

Link to this function

ack(atom, successful, failed)

View Source
Link to this function

handle_failed(messages, context)

View Source

Callback implementation for Broadway.handle_failed/2.

Link to this function

handle_message(_, message, _)

View Source

Callback implementation for Broadway.handle_message/3.

Link to this function

process_name(broadway_name, base_name)

View Source