[Improvement][Master] add max submit times of workflow

[fuchanghai]

Search before asking

• I had searched in the issues and found no similar feature requirement.

Description

when submit workflow failure , will resubmit workflow . if have not maximum number of submissions，will cause print a lot log which takes up a lot of resources

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[github-actions]

Thank you for your feedback, we have received your issue, Please wait patiently for a reply.

• In order for us to understand your request as soon as possible, please provide detailed information、version or pictures.
• If you haven't received a reply for a long time, you can join our slack and send your question to channel #troubleshooting

[fuchanghai]

• 1. add workflow.submit.max.times=10 in common.properties
• 2. add parameter private AtomicInteger maxSubmitTimes; in class of WorkflowEvent
• 3. when workflowSubmitStatue is fail after submit workflow, decrement maxSubmitTimes
• 4. when maxSubmitTimes equal 0 change processInstance's status to fail and update to DB
• 5. get WorkflowExecuteRunnable from processInstanceExecCacheManager by processInstanceId
• 6. add a special stateEvent , add update the method of handleEvents that get the specialstateEvent will throw a Exception
• 7. when WorkflowExecuteRunnable is fail will call the method onFailure that notify to parentProcessInstance

[fuchanghai]

cc @caishunfeng @ruanwenjun @SbloodyS @EricGao888 @DarkAssassinator

[ruanwenjun]

• 1. add workflow.submit.max.times=10 in common.properties
• 2. add parameter private AtomicInteger maxSubmitTimes; in class of WorkflowEvent

You don't need to use AtomicInteger, the event will not be consumed concurrently.

• 3. when workflowSubmitStatue is fail after submit workflow, decrement maxSubmitTimes
• 4. when maxSubmitTimes equal 0 change processInstance's status to fail and update to DB

You need to know when this event consume failed always due to the db crash, so it will throw exception when you update status.

• 5. get WorkflowExecuteRunnable from processInstanceExecCacheManager by processInstanceId
• 6. add a special stateEvent , add update the method of handleEvents that get the specialstateEvent will throw a Exception
• 7. when WorkflowExecuteRunnable is fail will call the method onFailure that notify to parentProcessInstance

[fuchanghai]

• 1. add workflow.submit.max.times=10 in application.yml
• 2. add parameter private int maxSubmitTimes; in class of WorkflowEvent
• 3. when workflowSubmitStatue is fail after submit workflow, decrement maxSubmitTimes
• 4. when maxSubmitTimes equal 0 get WorkflowExecuteRunnable sumbit a special stateEvent
• 6. update the method of handleEvents that get the specialstateEvent will update processInstance by id and run the method of endProcess

[github-actions]

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

[github-actions]

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.

[github-actions]

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.