-
Notifications
You must be signed in to change notification settings - Fork 113
Add more necessities to workflow-core
#2961
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
3c0869b to
8a4f1ec
Compare
78c2d92 to
729e674
Compare
Yicong-Huang
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Left some comments
core/micro-services/workflow-core/src/main/resources/workflow-core-config.yaml
Outdated
Show resolved
Hide resolved
...ervices/workflow-core/src/main/scala/edu/uci/ics/amber/storage/core/BufferedItemWriter.scala
Outdated
Show resolved
Hide resolved
core/micro-services/workflow-core/src/main/scala/edu/uci/ics/amber/WorkflowCoreConfig.scala
Outdated
Show resolved
Hide resolved
# Conflicts: # core/micro-services/build.sbt # core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/SqlServer.scala
This reverts commit 045b7ef.
729e674 to
d31a047
Compare
Yicong-Huang
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. Left some comments. Make sure all migrated modules reflect the new packaging naming.
core/micro-services/workflow-core/src/main/resources/workflow-core-config.yaml
Outdated
Show resolved
Hide resolved
...es/workflow-core/src/main/scala/edu/uci/ics/amber/core/executor/SourceOperatorExecutor.scala
Outdated
Show resolved
Hide resolved
...ices/workflow-core/src/main/scala/edu/uci/ics/amber/exception/WorkflowRuntimeException.scala
Outdated
Show resolved
Hide resolved
...vices/workflow-core/src/main/scala/edu/uci/ics/amber/storage/model/DatasetFileDocument.scala
Outdated
Show resolved
Hide resolved
...services/workflow-core/src/main/scala/edu/uci/ics/amber/storage/result/OpResultStorage.scala
Outdated
Show resolved
Hide resolved
core/micro-services/workflow-core/src/main/resources/workflow-core-config.yaml
Outdated
Show resolved
Hide resolved
core/micro-services/workflow-core/src/main/resources/workflow-core-config.yaml
Show resolved
Hide resolved
core/micro-services/workflow-core/src/main/resources/workflow-core-config.yaml
Show resolved
Hide resolved
core/micro-services/workflow-core/src/main/scala/edu/uci/ics/amber/util/ResourceUtils.scala
Outdated
Show resolved
Hide resolved
|
@bobbai00 make sure you update Pr description before merging |
This PR adds more definition to the `workflow-core` for future components to references. ### What items this PR adds These components include: - under `amber.core` - `WorkflowRuntimeException` - under `amber.core.executer` - `SinkOperatorExecutor` - `SourceOperatorExecutor` - under `amber.core.storage` - `model` => definitions including `BufferedItemWriter`, `VirtualCollection`, `VirtualDocument` and `DatasetFileDocument` - `result` => everything related to store execution results - `util` => utility functions used by storage - `StorageConfig` => config file reader - under `amber.util` - `PathUtils` for resolving some code repo file paths
This PR adds more definition to the
workflow-corefor future components to references.What items this PR adds
These components include:
amber.coreWorkflowRuntimeExceptionamber.core.executerSinkOperatorExecutorSourceOperatorExecutoramber.core.storagemodel=> definitions includingBufferedItemWriter,VirtualCollection,VirtualDocumentandDatasetFileDocumentresult=> everything related to store execution resultsutil=> utility functions used by storageStorageConfig=> config file readeramber.utilPathUtilsfor resolving some code repo file paths