This is an automated email from the ASF dual-hosted git repository.
shengquan pushed a commit to branch shengquan-add-reconfigration
in repository https://gitbox.apache.org/repos/asf/texera.git
The following commit(s) were added to refs/heads/shengquan-add-reconfigration
by this push:
new 9cc8802676 format fixes
9cc8802676 is described below
commit 9cc880267625580f179d1c04b80de18588cdd257
Author: Shengquan Ni <[email protected]>
AuthorDate: Sun Feb 15 01:44:13 2026 -0800
format fixes
---
.../handlers/control/update_executor_handler.py | 32 +++++++++++++++++++++-
common/config/src/main/resources/storage.conf | 4 +--
common/config/src/main/resources/udf.conf | 2 +-
.../texera/amber/operator/TestOperators.scala | 19 -------------
4 files changed, 34 insertions(+), 23 deletions(-)
diff --git
a/amber/src/main/python/core/architecture/handlers/control/update_executor_handler.py
b/amber/src/main/python/core/architecture/handlers/control/update_executor_handler.py
index a79d31c180..07353337aa 100644
---
a/amber/src/main/python/core/architecture/handlers/control/update_executor_handler.py
+++
b/amber/src/main/python/core/architecture/handlers/control/update_executor_handler.py
@@ -1 +1,31 @@
-# Licensed to the Apache Software Foundation (ASF) under one # or more
contributor license agreements. See the NOTICE file # distributed with this
work for additional information # regarding copyright ownership. The ASF
licenses this file # to you under the Apache License, Version 2.0 (the #
"License"); you may not use this file except in compliance # with the License.
You may obtain a copy of the License at # #
http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable
law or agreed to in writing, # software distributed under the License is
distributed on an # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY #
KIND, either express or implied. See the License for the # specific language
governing permissions and limitations # under the License. from
core.architecture.handlers.control.control_handler_base import ControlHandler
from proto.org.apache.texera.amber.engine.architecture.rpc import (
EmptyReturn, UpdateExecutorRequest, ) from core.util
import get_one_of from proto.org.apache.texera.amber.core import
OpExecWithCode class UpdateExecutorHandler(ControlHandler): async def
update_executor(self, req: UpdateExecutorRequest) -> EmptyReturn:
op_exec_with_code: OpExecWithCode = get_one_of(req.new_exec_init_info)
self.context.executor_manager.update_executor(op_exec_with_code.code, False)
return EmptyReturn()
\ No newline at end of file
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+from core.architecture.handlers.control.control_handler_base import
ControlHandler
+from proto.org.apache.texera.amber.engine.architecture.rpc import (
+ EmptyReturn,
+ UpdateExecutorRequest,
+)
+from core.util import get_one_of
+from proto.org.apache.texera.amber.core import OpExecWithCode
+
+
+class UpdateExecutorHandler(ControlHandler):
+ async def update_executor(self, req: UpdateExecutorRequest) -> EmptyReturn:
+ op_exec_with_code: OpExecWithCode = get_one_of(req.new_exec_init_info)
+ self.context.executor_manager.update_executor(op_exec_with_code.code,
False)
+ return EmptyReturn()
diff --git a/common/config/src/main/resources/storage.conf
b/common/config/src/main/resources/storage.conf
index f8b1868941..6ac5905765 100644
--- a/common/config/src/main/resources/storage.conf
+++ b/common/config/src/main/resources/storage.conf
@@ -37,7 +37,7 @@ storage {
username = "texera"
username = ${?STORAGE_ICEBERG_CATALOG_POSTGRES_USERNAME}
- password = "123456"
+ password = ""
password = ${?STORAGE_ICEBERG_CATALOG_POSTGRES_PASSWORD}
}
}
@@ -134,7 +134,7 @@ storage {
username = "postgres"
username = ${?STORAGE_JDBC_USERNAME}
- password = "123456"
+ password = ""
password = ${?STORAGE_JDBC_PASSWORD}
}
}
diff --git a/common/config/src/main/resources/udf.conf
b/common/config/src/main/resources/udf.conf
index c009aed0de..7212d1720e 100644
--- a/common/config/src/main/resources/udf.conf
+++ b/common/config/src/main/resources/udf.conf
@@ -17,7 +17,7 @@
python {
# python3 executable path
- path = "C:\\Users\\12198\\IdeaProjects\\texera\\.venv\\Scripts\\python.exe"
+ path = ""
path = ${?UDF_PYTHON_PATH}
log {
diff --git
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/TestOperators.scala
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/TestOperators.scala
index 0dedd09e1f..c602ccbdd3 100644
---
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/TestOperators.scala
+++
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/TestOperators.scala
@@ -176,27 +176,8 @@ object TestOperators {
|class ProcessTupleOperator(UDFOperatorV2):
| @overrides
| def process_tuple(self, tuple_: Tuple, port: int) ->
Iterator[Optional[TupleLike]]:
- | print(tuple_)
| yield tuple_
|""".stripMargin
udf
}
-
- def pythonSourceOpDesc(num_tuple: Int, delay_in_sec: Double):
PythonUDFSourceOpDescV2 = {
- val udf = new PythonUDFSourceOpDescV2()
- udf.workers = 1
- udf.columns = List(new Attribute("field_1", AttributeType.INTEGER), new
Attribute("field_2", AttributeType.STRING))
- udf.code =
- s"""
- |from pytexera import *
- |from time import sleep
- |class ProcessTupleOperator(UDFSourceOperator):
- | @overrides
- | def produce(self) -> Iterator[Union[TupleLike, TableLike, None]]:
- | for i in range($num_tuple):
- | sleep($delay_in_sec)
- | yield {'field_1': i, 'field_2': str(i)}
- |""".stripMargin
- udf
- }
}
