Skip to content

thlinhit/noop-flow

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

172 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

TODO

Open points

  • Task state in Step Function does not have guard.
  • Guard only used to verify the context. -> only useful on Choice Sate

Diagram

Build a generic interface:

State

https://towardsdatascience.com/airflow-state-101-2be3846d4634 https://docs.aws.amazon.com/step-functions/latest/dg/sample-project-job-poller.html

Database Design

flows: {

    shape: sql_table
  
    id: varchar(250) NOT NULL {constraint: primary_key}

    status: SMALLINT UNSIGNED NOT NULL

    flow_type_id: varchar(100) NOT NULL

    case_id: varchar(250) NOT NULL {constraint: unique}

    current_state: varchar(250) NOT NULL

    passed_states: TEXT NULL

    context: json NOT NULL
    
    created_date: datetime NOT NULL default CURRENT_TIMESTAMP
    last_updated_date: datetime NOT NULL default CURRENT_TIMESTAMP
    version: SMALLINT NOT NULL DEFAULT 0
}

descrition: |md
 ## Notes
    `composite_key`: <created_date, id, status>

    **status**: <0: RUNNING, 1: COMPLETED, 2:ERROR>
|

Buffered Events

https://stackoverflow.com/questions/56263335/job-queue-with-job-affinity/56615120#56615120 lock workflow, when it is being executed, and if an event comes and see it is being executed -> reschedule by Kafka topic.

https://tanzu.vmware.com/developer/guides/spring-integration-lock/ https://github.com/spring-projects/spring-integration/blob/c28e2510917ae0a2945865017a489adc1659d19f/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/JdbcLockRegistry.java

HOLD -> TRANSFER -> [triggered] SEND SMS -> RELEASE HOLD

https://medium.com/paypal-tech/a-birds-eye-view-on-java-concurrency-frameworks-5072fd3a8759

https://www.baeldung.com/concurrency-principles-patterns

https://github.com/Netflix/conductor/blob/248dc5b96304bfa33f420e31ae93799ef285ba18/core/src/main/java/com/netflix/conductor/core/execution/tasks/SystemTaskWorker.java

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

Packages

Used by

Contributors

Languages