pipeline.src.flows.email_actions_to_units

Functions

get_actions_period(→ src.helpers.dates.Period)

extract_mission_actions(→ pandas.DataFrame)

get_control_unit_ids(→ List[int])

filter_control_units(...)

to_control_unit_actions(...)

get_template(→ jinja2.Template)

render(→ str)

create_email(→ email.message.EmailMessage)

send_mission_actions_email(...)

Sends input email using the contents of From header as sender and To, Cc

control_unit_actions_list_to_df(→ pandas.DataFrame)

load_emails_sent_to_control_units(...)

email_actions_to_units_flow(test_mode, is_integration, ...)

Module Contents

pipeline.src.flows.email_actions_to_units.get_actions_period(utcnow: datetime.datetime, start_days_ago: int, end_days_ago: int) → src.helpers.dates.Period[source]
pipeline.src.flows.email_actions_to_units.extract_mission_actions(period: src.helpers.dates.Period) → pandas.DataFrame[source]
pipeline.src.flows.email_actions_to_units.get_control_unit_ids(env_action: pandas.DataFrame) → List[int][source]
pipeline.src.flows.email_actions_to_units.filter_control_units(all_control_units: List[src.entities.control_units.ControlUnit], control_unit_ids: List[str]) → List[src.entities.control_units.ControlUnit][source]
pipeline.src.flows.email_actions_to_units.to_control_unit_actions(mission_actions: pandas.DataFrame, period: src.helpers.dates.Period, control_units: List[src.entities.control_units.ControlUnit]) → List[src.entities.control_units.ControlUnitActions][source]
pipeline.src.flows.email_actions_to_units.get_template() → jinja2.Template[source]
pipeline.src.flows.email_actions_to_units.render(control_unit_actions: src.entities.control_units.ControlUnitActions, template: jinja2.Template) → str[source]
pipeline.src.flows.email_actions_to_units.create_email(html: str, actions: src.entities.control_units.ControlUnitActions, test_mode: bool) → email.message.EmailMessage[source]
pipeline.src.flows.email_actions_to_units.send_mission_actions_email(message: email.message.EmailMessage, actions: src.entities.control_units.ControlUnitActions, is_integration: bool) → List[src.entities.control_units.ControlUnitActionsSentMessage][source]

Sends input email using the contents of From header as sender and To, Cc and Bcc headers as recipients.

Parameters:

  • message (EmailMessage) – email message to send

  • actions (ControlUnitActions) – ControlUnitActions related to message

  • is_integration (bool) – if False, the message is not actually sent

Returns:

List of sent messages and their error codes, if any.

Return type:

List[ControlUnitActionsSentMessage]

pipeline.src.flows.email_actions_to_units.control_unit_actions_list_to_df(messages: List[src.entities.control_units.ControlUnitActionsSentMessage]) → pandas.DataFrame[source]
pipeline.src.flows.email_actions_to_units.load_emails_sent_to_control_units(emails_sent_to_control_units: pandas.DataFrame)[source]
pipeline.src.flows.email_actions_to_units.email_actions_to_units_flow(test_mode: bool, is_integration: bool, start_days_ago: int, end_days_ago: int, fetch_control_units_fn: Callable = fetch_control_units)[source]