Release v4.0.2a6

Author: zhongjiajie

src/pydolphinscheduler/__init__.py

@@ -17,4 +17,4 @@
 
 """Init root of pydolphinscheduler."""
 
-__version__ = "4.0.2a5"
+__version__ = "4.0.2a6"

src/pydolphinscheduler/default_config.yaml

@@ -23,7 +23,7 @@ java_gateway:
 
   # The address of Python gateway server start. Set its value to `0.0.0.0` if your Python API run in different
   # between Python gateway server. It could be be specific to other address like `127.0.0.1` or `localhost`
-  address: 127.0.0.1
+  address: ctyun5
 
   # The port of Python gateway server start. Define which port you could connect to Python gateway server from
   # Python API models.
@@ -39,16 +39,16 @@ java_gateway:
 default:
   # Default value for dolphinscheduler's user object
   user:
-    name: userPythonGateway
-    password: userPythonGateway
+    name: admin
+    password: dolphinscheduler123
     email: userPythonGateway@dolphinscheduler.com
-    tenant: tenant_pydolphin
+    tenant: whalescheduler
     phone: 11111111111
     state: 1
   # Default value for dolphinscheduler's workflow object
   workflow:
     project: project-pydolphin
-    user: userPythonGateway
+    user: admin
     queue: queuePythonGateway
     worker_group: default
     # Release state of workflow, default value is ``online`` which mean setting workflow online when it submits

src/pydolphinscheduler/examples/ext/example.sql

@@ -1,3 +1,4 @@
-select *
-from resource_plugin
-where id = 1
+create table test.table_one(id int, name varchar(30));
+insert into test.table_one values(1, 'a');
+create table test.table_two(id int, name varchar(30));
+insert into test.table_one values(2, 'b');

src/pydolphinscheduler/examples/task_sql_example.py

@@ -30,14 +30,14 @@
     # [start bare_sql_desc]
     bare_sql = Sql(
         name="bare_sql",
-        datasource_name="metadata",
+        datasource_name="whalescheduler",
         sql="select * from t_ds_version",
     )
     # [end bare_sql_desc]
     # [start sql_file_desc]
     sql_file = Sql(
         name="sql_file",
-        datasource_name="metadata",
+        datasource_name="whalescheduler",
         sql="ext/example.sql",
         sql_type=SqlType.SELECT,
         resource_plugin=Local(prefix=str(Path(__file__).parent)),
@@ -46,20 +46,17 @@
     # [start sql_with_pre_post_desc]
     sql_with_pre_post = Sql(
         name="sql_with_pre_post",
-        datasource_name="metadata",
+        datasource_name="whalescheduler",
         sql="select * from t_ds_version",
         pre_statements=[
-            "update table_one set version = '1.3.6'",
-            "delete from table_two where version = '1.3.6'",
+            "update test.table_one set name = '1.3.6'",
+            "delete from test.table_two where name = '1.3.6'",
         ],
-        post_statements="update table_one set version = '3.0.0'",
+        post_statements="update test.table_one set name = '3.0.0'",
     )
     # [end sql_with_pre_post_desc]
 
-    bare_sql >> [
-        sql_file,
-        sql_with_pre_post,
-    ]
+    bare_sql >> sql_file >> sql_with_pre_post
 
     workflow.submit()
 

src/pydolphinscheduler/examples/tutorial.py

@@ -45,6 +45,8 @@
     name="tutorial",
     schedule="0 0 0 * * ? *",
     start_time="2021-01-01",
+    online_schedule=False,
+    release_state="offline",
 ) as workflow:
     # [end workflow_declare]
     # [start task_declare]
@@ -62,6 +64,6 @@
     # [end task_relation_declare]
 
     # [start submit_or_run]
-    workflow.run()
+    workflow.submit()
     # [end submit_or_run]
 # [end tutorial]