private createStateMachine()

in cdk/lib/syndication-workflow.ts [44:66]

19 lines of code
1 McCabe index (conditional complexity)


    private createStateMachine() {
        const Ace = new AceResources(this, "AceResources", this.sourceBucket, this.partnerACEDestinationBucketName, this.mediaConvertEndpointURL);
        const OtherProvider = new OtherPartnerResources(this, "OtherPartner", this.sourceBucket);

        const CheckPartnerEntitlement = Util.makeLambdaInvokeTaskFromJSFunction(this, "shared", "CheckPartnerEntitlement");
        const ReportResult = Util.makeLambdaInvokeTaskFromJSFunction(this, "shared", "ReportResult");

        const ParallelPartnerWorkflowProcessing = new sfn.Parallel(this, "ParallelPartnerProcessing")
            .branch(
                Ace.workflowDefinition,
                OtherProvider.workflowDefinition
            );

        const SyndicationWorkflowDefinition = CheckPartnerEntitlement
            .next(ParallelPartnerWorkflowProcessing)
            .next(ReportResult);

        return new sfn.StateMachine(this, "SyndicationStateMachine", {
            definition: SyndicationWorkflowDefinition,
            timeout: cdk.Duration.minutes(60),
            stateMachineName: "Syndication"
        });
    }