def orchestrator_function(context: df.DurableOrchestrationContext):
    """Get Anomaly data from durable orchestration context and schedule an activity for execution.

    Args:
        context (df.DurableOrchestrationContext): Context of the durable orchestration execution.

    Returns:
        str: result of Activity function
    """
    applogger.info("{} AnomalyOrchestrator function called!".format(LOGS_STARTS_WITH))
    json_data = context.get_input()
    result1 = yield context.call_activity(
        "RubrikActivity", {"data": json_data, "log_type": ANOMALY_LOG_TYPE}
    )
    applogger.info(
        "{} AnomalyOrchestrator function completed!".format(LOGS_STARTS_WITH)
    )
    return result1
Get Anomaly data from durable orchestration context and schedule an activity for execution.

    Args:
        context (df.DurableOrchestrationContext): Context of the durable orchestration execution.

    Returns:
        str: result of Activity function
    
Solutions/RubrikSecurityCloud/Data Connectors/RubrikWebhookEvents/RubrikAnomalyOrchestrator/__init__.py