Task input type#87

Merged

qdaxb merged 274 commits intomainfrom task_input_type

Oct 31, 2024

+541-50

This pull request is big! We're only showing the most recent 250 commits

Commits on Sep 12, 2024

do run AnswerTaskRunner and AnswerTaskDispatcher
zeyu10
committed
rename answer task runner
zeyu10
committed
add icon for answer task
zeyu10
committed
add tolerance logic for answer task runner
zeyu10
committed
fix wrong resourceProtocol
zeyu10
committed
schedule answer task
zeyu10
committed
schedule answer task
zeyu10
committed

Commits on Sep 13, 2024

add comments
zeyu10
committed
Improve task filtering logic for ready-to-run tasks
zeyu10
committed

Commits on Sep 14, 2024

extract static final variable
zeyu10
committed

Commits on Sep 18, 2024

use uriBuilder to refactor SseProtocolDispatcher to improve error handling and logging
zeyu10
committed
remove useless params
zeyu10
committed
use uribuilder to build url in SseProtocolDispatcher
zeyu10
committed
use uribuilder to build url in SseProtocolDispatcher
zeyu10
committed
fix nullpoint exception
zeyu10
committed
add unit test for AnswerTaskRunnegr
zeyu10
committed
add unit test for updateDagStatus update invoke time info
zeyu10
committed
add unit test for DAGDescriptorFacade.generateResourceProtocol
zeyu10
committed
add unit test for DAGDescriptorFacade.generateResourceProtocol
zeyu10
committed
add unit test for DAGWalkHelper to test without answer node
zeyu10
committed

Commits on Sep 19, 2024

check whether is key mode
zeyu10
committed
check whether is key mode
zeyu10
committed
check whether is key mode
zeyu10
committed
allow callback_info in header
zeyu10
committed
optimit code
zeyu10
committed
add unit test to test when answer node is key callback in key mode
zeyu10
committed
add comments
zeyu10
committed
add unit test
zeyu10
committed
add unit test to test buildUrl in SseProtocolDispatcher
zeyu10
committed
optimit code
zeyu10
committed
add unit test to test buildHttpEntity in SseProtocolDispatcher
zeyu10
committed
add unit test to test handle in SseProtocolDispatcher
zeyu10
committed
test buildHttpEntity without callback info
zeyu10
committed
test getReadyToRunTasks answer after answer
zeyu10
committed
add unit test to test AnswerTaskRunner.doRun when answerTask is null
zeyu10
committed
add unit test to test AnswerTaskRunner.doRun when answerTask is null
zeyu10
committed

Commits on Sep 20, 2024

add unit test to test AnswerTaskRunner.doRun when dispatch error
zeyu10
committed
fix sonar
zeyu10
committed
fix sonar
zeyu10
committed
fix sonar
zeyu10
committed
add unit test to test AnswerTaskDispatcher
zeyu10
committed
add unit test to test AnswerTask
zeyu10
committed
add unit test to test AnswerTask
zeyu10
committed

Commits on Sep 23, 2024

Commits on Sep 29, 2024

change answer task to stream input task
zeyu10
committed
fix unit test
zeyu10
committed
fix unit test
zeyu10
committed
fix issue
zeyu10
committed

Commits on Sep 30, 2024

add rill_flow_host parameter when calling aggregate/execute.json
zeyu10
committed
remove useless parameter
zeyu10
committed
add X-Flow-Server header
zeyu10
committed

Commits on Oct 9, 2024

fix sonar
zeyu10
committed
remove sseProtocolDispatcher
zeyu10
committed

Commits on Oct 10, 2024

Commits on Oct 11, 2024

add output type
zeyu10
committed
fix unit test
zeyu10
committed

Commits on Oct 15, 2024

Commits on Oct 16, 2024

add todo mark
zeyu10
committed
add unit test to drive the development
zeyu10
committed
auto generate output mappings
zeyu10
committed
modify gitignore
zeyu10
committed
add the situation that contains dot in mapping elements
zeyu10
committed
remove useless variable
zeyu10
committed
optimit code
zeyu10
committed
adapt v2.0 when get descriptors
zeyu10
committed
adapt v2.0 when get descriptors
zeyu10
committed
remove context keyword in v2.0 version
zeyu10
committed

Commits on Oct 17, 2024

process inputMappings when set and get descriptor
zeyu10
committed
fix index error in processInputMappingsWhenGetDescriptor and add unit test
zeyu10
committed
optimit code
zeyu10
committed
add input keyword to generate inputMappings and outputMappings
zeyu10
committed
fix unit test
zeyu10
committed
not limit version
zeyu10
committed
remove useless variable
zeyu10
committed
optimit code
zeyu10
committed
generate end pass task
zeyu10
committed
generate end pass task
zeyu10
committed
fix unit test
zeyu10
committed
fix unit test
zeyu10
committed
fix sonar
zeyu10
committed
fix sonar
zeyu10
committed
change endtaskname
zeyu10
committed

Commits on Oct 18, 2024

add unit test for generating end pass task
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
extract code into DescriptorParseService and implement
zeyu10
committed
extract code into DescriptorParseService and implement
zeyu10
committed
add unit test for processWhenGetDescriptor and only use this method for web getting
zeyu10
committed
fix error when element is number
zeyu10
committed
allow array in json path when mapping
zeyu10
committed
allow array in json path when mapping
zeyu10
committed
allow array in json path when mapping
zeyu10
committed
recovery useless modify
zeyu10
committed

Commits on Oct 21, 2024

remove logic to merge common prefixes and add logic to remove duplicate output
zeyu10
committed
remove useless modify
zeyu10
committed
modify unit test
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
recovery useless modify
zeyu10
committed
recovery useless modify
zeyu10
committed
remove useless modify
zeyu10
committed
modify comments
zeyu10
committed
complete processInputMappingsWhenGetDescriptor
zeyu10
committed
complete processInputMappingsWhenGetDescriptor
zeyu10
committed
complete processInputMappingsWhenGetDescriptor
zeyu10
committed
complete processInputMappingsWhenGetDescriptor
zeyu10
committed
optimit code
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
add comments
zeyu10
committed
modify return type from array to List
zeyu10
committed
merge generate_output_mappings and resolve conflicts
zeyu10
committed
rename InputType to TaskInputOutputType
zeyu10
committed
add output type into function.json
zeyu10
committed

Commits on Oct 22, 2024

Commits on Oct 23, 2024

move all the calls of descriptorParseService into DescriptorManager
zeyu10
committed
use strategy design pattern to redesign dag process
zeyu10
committed
optimit code
zeyu10
committed
add unit tests
zeyu10
committed
fix sonar
zeyu10
committed
fix sonar
zeyu10
committed
fix sonar
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
add license
zeyu10
committed

Commits on Oct 24, 2024

modify enter
zeyu10
committed
modify enter
zeyu10
committed
add license and comments
zeyu10
committed
add license and comments
zeyu10
committed
rename method name
zeyu10
committed
rename method name
zeyu10
committed
redesign DescriptorManager method
zeyu10
committed
fix unit test
zeyu10
committed
modify method name
zeyu10
committed
modify method name
zeyu10
committed
add comments
zeyu10
committed
Merge branch 'generate_output_mappings' of github.com:weibocom/rill-flow into task_input_type
zeyu10
committed
create dag descriptor converter
zeyu10
committed
create dag descriptor converter
zeyu10
committed
create dag descriptor converter
zeyu10
committed
fix unit test
zeyu10
committed
move converter into converter package
zeyu10
committed
modify DO to PO
zeyu10
committed
modify DO to PO
zeyu10
committed

Commits on Oct 25, 2024

Commits on Oct 28, 2024

add unit test for JSONPathInputOutputMapping and fix problem
zeyu10
committed
add unit test for JSONPathInputOutputMapping and fix problem
zeyu10
committed
Merge branch 'dag_descriptor_converter' of github.com:weibocom/rill-flow into task_input_type
zeyu10
committed
Merge branch 'task_input_type' of github.com:weibocom/rill-flow into task_input_type
zeyu10
committed
remove useless comments
zeyu10
committed
add unit test for JSONPathInputOutputMapping
zeyu10
committed
use LinkedHashMultimap to rebuild DAGDescriptorConverterImpl
zeyu10
committed
optimit code
zeyu10
committed
modify comments
zeyu10
committed
optimit code
zeyu10
committed
optimit code
zeyu10
committed
Merge branch 'dag_descriptor_converter' of github.com:weibocom/rill-flow into task_input_type
zeyu10
committed
rename method name
zeyu10
committed
rename method name
zeyu10
committed
rename DescriptorManager into DAGDescriptorManager
zeyu10
committed
extract DAGDescriptorManager into daos
zeyu10
committed
add license and comments
zeyu10
committed
add license and comments
zeyu10
committed
extract dao
zeyu10
committed
add unit test for DAGABTestDAOTest
zeyu10
committed
rename DAGDescriptorUtil to DAGStorageKeysUtil
zeyu10
committed
add unit test for DAGAliasDAO
zeyu10
committed

Commits on Oct 29, 2024

add unit test for DAGDescriptorDAO
zeyu10
committed
add unit test for daos
zeyu10
committed
add license and comments
zeyu10
committed
add unit test for daos
zeyu10
committed
add unit test for DAGDescriptorFacade
zeyu10
committed
add unit test for DAGDescriptorFacade
zeyu10
committed
add unit test for DAGDescriptorService
zeyu10
committed
add license
zeyu10
committed
add license
zeyu10
committed
optimit code
zeyu10
committed
add unit test for FunctionTaskService
zeyu10
committed
use getDAG instead of getDescriptorDO
zeyu10
committed
resolve conflicts
zeyu10
committed
add comments
zeyu10
committed
Merge branch 'extract_dag_descriptor_dao' of github.com:weibocom/rill-flow into task_input_type
zeyu10
committed
resolve conflicts
zeyu10
committed
recovery useless modify
zeyu10
committed
recovery useless modify
zeyu10
committed
recovery useless modify
zeyu10
committed
recovery useless modify
zeyu10
committed
add @JsonProperty
zeyu10
committed
add @JsonProperty
zeyu10
committed
add @JsonAlias("key_callback")
zeyu10
committed
add @JsonAlias
zeyu10
committed
rename field
zeyu10
committed
add @JsonAlias
zeyu10
committed
add @JsonAlias
zeyu10
committed
add @JsonAlias
zeyu10
committed

Commits on Oct 30, 2024

remove useless import
zeyu10
committed
add comments
zeyu10
committed
modify comments
zeyu10
committed
split judgement to let code easy to be read
zeyu10
committed
optimit code
zeyu10
committed
modify unit test
zeyu10
committed
modify unit test
zeyu10
committed
extract method
zeyu10
committed
modify comments
zeyu10
committed
modify comments
zeyu10
committed
optimit code
zeyu10
committed
add unit test to test getReadyToRunTasks when there are multiple stream input tasks
zeyu10
committed
optimit code
zeyu10
committed