This is an automated email from the ASF dual-hosted git repository. zhongjiajie pushed a commit to branch 4.0.x in repository https://gitbox.apache.org/repos/asf/dolphinscheduler-sdk-python.git
commit 3a8a4e31219167a83c136ac52d0ef87960279310 Author: Jay Chung <[email protected]> AuthorDate: Mon Apr 3 16:22:28 2023 +0800 fix: Upload resource error in 4.0.x --- src/pydolphinscheduler/core/resource.py | 1 + src/pydolphinscheduler/java_gateway.py | 8 ++++++-- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/pydolphinscheduler/core/resource.py b/src/pydolphinscheduler/core/resource.py index 907114f..3925fb5 100644 --- a/src/pydolphinscheduler/core/resource.py +++ b/src/pydolphinscheduler/core/resource.py @@ -68,5 +68,6 @@ class Resource(Base): return gateway.create_or_update_resource( self.user_name, self.name, + self.description, self.content, ) diff --git a/src/pydolphinscheduler/java_gateway.py b/src/pydolphinscheduler/java_gateway.py index 91243f6..aeb6d04 100644 --- a/src/pydolphinscheduler/java_gateway.py +++ b/src/pydolphinscheduler/java_gateway.py @@ -124,9 +124,13 @@ class GatewayEntryPoint: """Get resources file info through java gateway.""" return self.gateway.entry_point.getResourcesFileInfo(program_type, main_package) - def create_or_update_resource(self, user_name: str, name: str, content: str): + def create_or_update_resource( + self, user_name: str, name: str, description: str, content: str + ): """Create or update resource through java gateway.""" - return self.gateway.entry_point.createOrUpdateResource(user_name, name, content) + return self.gateway.entry_point.createOrUpdateResource( + user_name, name, description, content + ) def query_resources_file_info(self, user_name: str, name: str): """Get resources file info through java gateway."""
