def orchestrator_function(context: df.DurableOrchestrationContext):
    """Get Ransomware 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(
        "{} RansomwareOrchestrator function called!".format(LOGS_STARTS_WITH)
    )
    json_data = context.get_input()
    result1 = yield context.call_activity(
        "RubrikActivity", {"data": json_data, "log_type": RANSOMWARE_LOG_TYPE}
    )
    applogger.info(
        "{} RansomwareOrchestrator function completed!".format(LOGS_STARTS_WITH)
    )
    return result1
Get Ransomware 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/RubrikRansomwareOrchestrator/__init__.py