This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler-website.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 51c52c382 Automated deployment:
a7d0de2b86d26e21479d52cb2b94d34fc8d5c7be
51c52c382 is described below
commit 51c52c3827bc001446f102129d490912b96f7797
Author: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jun 24 05:10:03 2022 +0000
Automated deployment: a7d0de2b86d26e21479d52cb2b94d34fc8d5c7be
---
.../guide/installation/pseudo-cluster.html | 3 +-
.../guide/installation/pseudo-cluster.json | 2 +-
python/_modules/pydolphinscheduler/constants.html | 6 +
.../core/process_definition.html | 1 +
python/_modules/pydolphinscheduler/core/task.html | 28 ++-
python/api.html | 192 +++++++++++++++++++++
python/genindex.html | 72 +++++++-
python/objects.inv | Bin 5793 -> 5954 bytes
python/searchindex.js | 2 +-
.../guide/installation/pseudo-cluster.html | 3 +-
.../guide/installation/pseudo-cluster.json | 2 +-
11 files changed, 303 insertions(+), 8 deletions(-)
diff --git a/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.html
b/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.html
index 89a134e92..acd169ba9 100644
--- a/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.html
+++ b/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.html
@@ -133,7 +133,8 @@ export DATAX_HOME=${DATAX_HOME:-/opt/soft/datax}
export
PATH=$HADOOP_HOME/bin:$SPARK_HOME1/bin:$SPARK_HOME2/bin:$PYTHON_HOME/bin:$JAVA_HOME/bin:$HIVE_HOME/bin:$FLINK_HOME/bin:$DATAX_HOME/bin:$PATH
</code></pre>
<h2>Initialize the Database</h2>
-<p>DolphinScheduler metadata is stored in the relational database. Currently,
supports PostgreSQL and MySQL. If you use MySQL, you need to manually download
<a href="https://downloads.MySQL.com/archives/c-j/";>mysql-connector-java
driver</a> (8.0.16) and move it to the lib directory of DolphinScheduler, which
is <code>tools/libs/</code>. Let's take MySQL as an example for how to
initialize the database:</p>
+<p>DolphinScheduler metadata is stored in the relational database. Currently,
supports PostgreSQL and MySQL. If you use MySQL, you need to manually download
<a href="https://downloads.MySQL.com/archives/c-j/";>mysql-connector-java
driver</a> (8.0.16) and move it to the libs directory of DolphinScheduler
+which is <code>api-server/libs/</code> and <code>alert-server/libs</code> and
<code>master-server/libs</code> and <code>worker-server/libs</code>. Let's take
MySQL as an example for how to initialize the database:</p>
<p>For mysql 5.6 / 5.7</p>
<pre><code class="language-shell">mysql -uroot -p
<span class="hljs-meta">
diff --git a/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.json
b/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.json
index 0c3c76a33..bfa54fb1e 100644
--- a/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.json
+++ b/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.json
@@ -1,6 +1,6 @@
{
"filename": "pseudo-cluster.md",
- "__html": "<h1>Pseudo-Cluster Deployment</h1>\n<p>The purpose of the
pseudo-cluster deployment is to deploy the DolphinScheduler service on a single
machine. In this mode, DolphinScheduler's master, worker, API server, are all
on the same machine.</p>\n<p>If you are a new hand and want to experience
DolphinScheduler functions, we recommend you install follow <a
href=\"standalone.md\">Standalone deployment</a>. If you want to experience
more complete functions and schedule massive tasks [...]
+ "__html": "<h1>Pseudo-Cluster Deployment</h1>\n<p>The purpose of the
pseudo-cluster deployment is to deploy the DolphinScheduler service on a single
machine. In this mode, DolphinScheduler's master, worker, API server, are all
on the same machine.</p>\n<p>If you are a new hand and want to experience
DolphinScheduler functions, we recommend you install follow <a
href=\"standalone.md\">Standalone deployment</a>. If you want to experience
more complete functions and schedule massive tasks [...]
"link":
"/dist/en-us/docs/dev/user_doc/guide/installation/pseudo-cluster.html",
"meta": {}
}
\ No newline at end of file
diff --git a/python/_modules/pydolphinscheduler/constants.html
b/python/_modules/pydolphinscheduler/constants.html
index c50d4fc5e..9c2581534 100644
--- a/python/_modules/pydolphinscheduler/constants.html
+++ b/python/_modules/pydolphinscheduler/constants.html
@@ -175,6 +175,12 @@
<span class="n">FMT_STD_TIME</span> <span class="o">=</span> <span
class="s2">"%H:%M:%S"</span>
<span class="n">FMT_NO_COLON_TIME</span> <span class="o">=</span> <span
class="s2">"%H%M%S"</span></div>
+
+
+<div class="viewcode-block" id="ResourceKey"><a class="viewcode-back"
href="../../api.html#pydolphinscheduler.constants.ResourceKey">[docs]</a><span
class="k">class</span> <span class="nc">ResourceKey</span><span
class="p">(</span><span class="nb">str</span><span class="p">):</span>
+ <span class="sd">"""Constants for key of
resource."""</span>
+
+ <span class="n">ID</span> <span class="o">=</span> <span
class="s2">"id"</span></div>
</pre></div>
</div>
diff --git a/python/_modules/pydolphinscheduler/core/process_definition.html
b/python/_modules/pydolphinscheduler/core/process_definition.html
index 47c3e647f..6cd627f64 100644
--- a/python/_modules/pydolphinscheduler/core/process_definition.html
+++ b/python/_modules/pydolphinscheduler/core/process_definition.html
@@ -480,6 +480,7 @@
<span class="n">json</span><span class="o">.</span><span
class="n">dumps</span><span class="p">(</span><span class="bp">self</span><span
class="o">.</span><span class="n">task_relation_json</span><span
class="p">),</span>
<span class="n">json</span><span class="o">.</span><span
class="n">dumps</span><span class="p">(</span><span class="bp">self</span><span
class="o">.</span><span class="n">task_definition_json</span><span
class="p">),</span>
<span class="kc">None</span><span class="p">,</span>
+ <span class="kc">None</span><span class="p">,</span>
<span class="p">)</span>
<span class="k">return</span> <span class="bp">self</span><span
class="o">.</span><span class="n">_process_definition_code</span></div>
diff --git a/python/_modules/pydolphinscheduler/core/task.html
b/python/_modules/pydolphinscheduler/core/task.html
index 9a3a20b98..9bf7eae62 100644
--- a/python/_modules/pydolphinscheduler/core/task.html
+++ b/python/_modules/pydolphinscheduler/core/task.html
@@ -97,6 +97,7 @@
<span class="kn">from</span> <span
class="nn">pydolphinscheduler.constants</span> <span class="kn">import</span>
<span class="p">(</span>
<span class="n">Delimiter</span><span class="p">,</span>
+ <span class="n">ResourceKey</span><span class="p">,</span>
<span class="n">TaskFlag</span><span class="p">,</span>
<span class="n">TaskPriority</span><span class="p">,</span>
<span class="n">TaskTimeoutFlag</span><span class="p">,</span>
@@ -230,7 +231,7 @@
<span class="c1"># Attribute for task param</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">local_params</span> <span class="o">=</span> <span
class="n">local_params</span> <span class="ow">or</span> <span
class="p">[]</span>
- <span class="bp">self</span><span class="o">.</span><span
class="n">resource_list</span> <span class="o">=</span> <span
class="n">resource_list</span> <span class="ow">or</span> <span
class="p">[]</span>
+ <span class="bp">self</span><span class="o">.</span><span
class="n">_resource_list</span> <span class="o">=</span> <span
class="n">resource_list</span> <span class="ow">or</span> <span
class="p">[]</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">dependence</span> <span class="o">=</span> <span
class="n">dependence</span> <span class="ow">or</span> <span class="p">{}</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">wait_start_timeout</span> <span class="o">=</span> <span
class="n">wait_start_timeout</span> <span class="ow">or</span> <span
class="p">{}</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">_condition_result</span> <span class="o">=</span> <span
class="n">condition_result</span> <span class="ow">or</span> <span
class="bp">self</span><span class="o">.</span><span
class="n">DEFAULT_CONDITION_RESULT</span>
@@ -245,6 +246,22 @@
<span class="sd">"""Set attribute
process_definition."""</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">_process_definition</span> <span class="o">=</span> <span
class="n">process_definition</span>
+ <span class="nd">@property</span>
+ <span class="k">def</span> <span class="nf">resource_list</span><span
class="p">(</span><span class="bp">self</span><span class="p">)</span> <span
class="o">-></span> <span class="n">List</span><span class="p">:</span>
+ <span class="sd">"""Get task define attribute
`resource_list`."""</span>
+ <span class="n">resources</span> <span class="o">=</span> <span
class="nb">set</span><span class="p">()</span>
+ <span class="k">for</span> <span class="n">resource</span> <span
class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span
class="n">_resource_list</span><span class="p">:</span>
+ <span class="k">if</span> <span class="nb">type</span><span
class="p">(</span><span class="n">resource</span><span class="p">)</span> <span
class="o">==</span> <span class="nb">str</span><span class="p">:</span>
+ <span class="n">resources</span><span class="o">.</span><span
class="n">add</span><span class="p">(</span><span class="bp">self</span><span
class="o">.</span><span class="n">query_resource</span><span
class="p">(</span><span class="n">resource</span><span class="p">)</span><span
class="o">.</span><span class="n">get</span><span class="p">(</span><span
class="n">ResourceKey</span><span class="o">.</span><span
class="n">ID</span><span class="p">))</span>
+ <span class="k">elif</span> <span class="nb">type</span><span
class="p">(</span><span class="n">resource</span><span class="p">)</span> <span
class="o">==</span> <span class="nb">dict</span> <span class="ow">and</span>
<span class="n">resource</span><span class="o">.</span><span
class="n">get</span><span class="p">(</span><span
class="n">ResourceKey</span><span class="o">.</span><span
class="n">ID</span><span class="p">)</span> <span class="ow">is</span> <span
class="ow">not< [...]
+ <span class="n">logger</span><span class="o">.</span><span
class="n">warning</span><span class="p">(</span>
+ <span class="sd">"""`resource_list` should
be defined using List[str] with resource paths,</span>
+<span class="sd"> the use of ids to define resources
will be remove in version 3.2.0.</span>
+<span class="sd"> """</span>
+ <span class="p">)</span>
+ <span class="n">resources</span><span class="o">.</span><span
class="n">add</span><span class="p">(</span><span
class="n">resource</span><span class="o">.</span><span
class="n">get</span><span class="p">(</span><span
class="n">ResourceKey</span><span class="o">.</span><span
class="n">ID</span><span class="p">))</span>
+ <span class="k">return</span> <span class="p">[{</span><span
class="n">ResourceKey</span><span class="o">.</span><span
class="n">ID</span><span class="p">:</span> <span class="n">r</span><span
class="p">}</span> <span class="k">for</span> <span class="n">r</span> <span
class="ow">in</span> <span class="n">resources</span><span class="p">]</span>
+
<span class="nd">@property</span>
<span class="k">def</span> <span class="nf">condition_result</span><span
class="p">(</span><span class="bp">self</span><span class="p">)</span> <span
class="o">-></span> <span class="n">Dict</span><span class="p">:</span>
<span class="sd">"""Get attribute
condition_result."""</span>
@@ -352,7 +369,14 @@
<span class="p">)</span>
<span class="c1"># result =
gateway.entry_point.genTaskCodeList(DefaultTaskCodeNum.DEFAULT)</span>
<span class="c1"># gateway_result_checker(result)</span>
- <span class="k">return</span> <span class="n">result</span><span
class="o">.</span><span class="n">get</span><span class="p">(</span><span
class="s2">"code"</span><span class="p">),</span> <span
class="n">result</span><span class="o">.</span><span class="n">get</span><span
class="p">(</span><span class="s2">"version"</span><span
class="p">)</span></div></div>
+ <span class="k">return</span> <span class="n">result</span><span
class="o">.</span><span class="n">get</span><span class="p">(</span><span
class="s2">"code"</span><span class="p">),</span> <span
class="n">result</span><span class="o">.</span><span class="n">get</span><span
class="p">(</span><span class="s2">"version"</span><span
class="p">)</span></div>
+
+<div class="viewcode-block" id="Task.query_resource"><a class="viewcode-back"
href="../../../api.html#pydolphinscheduler.core.Task.query_resource">[docs]</a>
<span class="k">def</span> <span class="nf">query_resource</span><span
class="p">(</span><span class="bp">self</span><span class="p">,</span> <span
class="n">full_name</span><span class="p">):</span>
+ <span class="sd">"""Get resource info from java
gateway, contains resource id, name."""</span>
+ <span class="n">gateway</span> <span class="o">=</span> <span
class="n">launch_gateway</span><span class="p">()</span>
+ <span class="k">return</span> <span class="n">gateway</span><span
class="o">.</span><span class="n">entry_point</span><span
class="o">.</span><span class="n">queryResourcesFileInfo</span><span
class="p">(</span>
+ <span class="bp">self</span><span class="o">.</span><span
class="n">process_definition</span><span class="o">.</span><span
class="n">user</span><span class="o">.</span><span class="n">name</span><span
class="p">,</span> <span class="n">full_name</span>
+ <span class="p">)</span></div></div>
</pre></div>
</div>
diff --git a/python/api.html b/python/api.html
index 874a52ff7..6c57cb2df 100644
--- a/python/api.html
+++ b/python/api.html
@@ -225,6 +225,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get resource info from java gateway, contains resource id, name.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.core.Engine.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.core.Engine.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.core.Engine.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -274,6 +280,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.core.Engine.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.core.Engine.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.core.Engine.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.core.Engine.task_params" title="Permalink to this
definition"></a></dt>
@@ -529,6 +541,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py" id="pydolphinscheduler.core.Task.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="reference internal"
href="_modules/pydolphinscheduler/core/task.html#Task.query_resource"><span
class="viewcode-link"><span class="pre">[source]</span></span></a><a
class="headerlink" href="#pydolphinscheduler.core.Task.query_resource"
title="Permalink to [...]
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py" id="pydolphinscheduler.core.Task.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -578,6 +596,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py" id="pydolphinscheduler.core.Task.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.core.Task.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.core.Task.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Optional</span><span class="p"><span
class="pre">[</span></span><span class="pre">Dict</span><span class="p"><span
class="pre">]</span></span></em><a class="headerlink"
href="#pydolphinscheduler.core.Task.task_params" titl [...]
@@ -851,6 +875,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Condition.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Condition.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Condition.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -915,6 +945,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Condition.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Condition.resource_list" title="Permalink to
this definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Condition.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Condition.task_params" title="Permalink to this
definition"></a></dt>
@@ -967,6 +1003,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.DataX.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.DataX.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.DataX.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1036,6 +1078,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.DataX.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.DataX.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.DataX.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.DataX.task_params" title="Permalink to this
definition"></a></dt>
@@ -1080,6 +1128,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Dependent.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Dependent.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Dependent.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1144,6 +1198,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Dependent.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Dependent.resource_list" title="Permalink to
this definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Dependent.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Dependent.task_params" title="Permalink to this
definition"></a></dt>
@@ -1201,6 +1261,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get resource info from java gateway, contains resource id, name.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Flink.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Flink.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Flink.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1265,6 +1331,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Flink.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Flink.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Flink.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Flink.task_params" title="Permalink to this
definition"></a></dt>
@@ -1309,6 +1381,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Http.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Http.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Http.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1373,6 +1451,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Http.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Http.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Http.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Optional</span><span class="p"><span
class="pre">[</span></span><span class="pre">Dict</span><span class="p"><span
class="pre">]</span></span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Http.task_params" tit [...]
@@ -1428,6 +1512,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get resource info from java gateway, contains resource id, name.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py" id="pydolphinscheduler.tasks.MR.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.MR.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.MR.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1492,6 +1582,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py" id="pydolphinscheduler.tasks.MR.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.MR.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.MR.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.MR.task_params" title="Permalink to this
definition"></a></dt>
@@ -1547,6 +1643,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Procedure.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Procedure.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Procedure.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1611,6 +1713,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Procedure.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Procedure.resource_list" title="Permalink to
this definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Procedure.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Procedure.task_params" title="Permalink to this
definition"></a></dt>
@@ -1684,6 +1792,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Python.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Python.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Python.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1754,6 +1868,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get python task define attribute <cite>raw_script</cite>.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Python.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Python.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Python.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Optional</span><span class="p"><span
class="pre">[</span></span><span class="pre">Dict</span><span class="p"><span
class="pre">]</span></span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Python.task_params" t [...]
@@ -1819,6 +1939,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Shell.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Shell.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Shell.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -1883,6 +2009,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Shell.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Shell.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Shell.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Optional</span><span class="p"><span
class="pre">[</span></span><span class="pre">Dict</span><span class="p"><span
class="pre">]</span></span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Shell.task_params" ti [...]
@@ -1938,6 +2070,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get resource info from java gateway, contains resource id, name.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Spark.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Spark.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Spark.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -2002,6 +2140,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Spark.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Spark.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Spark.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Spark.task_params" title="Permalink to this
definition"></a></dt>
@@ -2057,6 +2201,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Sql.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Sql.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Sql.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -2121,6 +2271,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Sql.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Sql.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Sql.sql_type">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">sql_type</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">str</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Sql.sql_type" title="Permalink to this
definition"></a></dt>
@@ -2180,6 +2336,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get process definition info from java gateway, contains process
definition id, name, code.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.SubProcess.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.SubProcess.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.SubProcess.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -2250,6 +2412,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get process definition code, a wrapper for <a class="reference
internal"
href="#pydolphinscheduler.tasks.SubProcess.get_process_definition_info"
title="pydolphinscheduler.tasks.SubProcess.get_process_definition_info"><code
class="xref py py-func docutils literal notranslate"><span
class="pre">get_process_definition_info()</span></code></a>.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.SubProcess.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.SubProcess.resource_list" title="Permalink to
this definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.SubProcess.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Optional</span><span class="p"><span
class="pre">[</span></span><span class="pre">Dict</span><span class="p"><span
class="pre">]</span></span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.SubProcess.task_param [...]
@@ -2301,6 +2469,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get object definition attribute by given attr set.</p>
</dd></dl>
+<dl class="py method">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Switch.query_resource">
+<span class="sig-name descname"><span
class="pre">query_resource</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span
class="pre">full_name</span></span></em><span class="sig-paren">)</span><a
class="headerlink" href="#pydolphinscheduler.tasks.Switch.query_resource"
title="Permalink to this definition"></a></dt>
+<dd><p>Get resource info from java gateway, contains resource id, name.</p>
+</dd></dl>
+
<dl class="py method">
<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Switch.set_downstream">
<span class="sig-name descname"><span
class="pre">set_downstream</span></span><span class="sig-paren">(</span><em
class="sig-param"><span class="n"><span class="pre">tasks</span></span><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="n"><span class="pre">Union</span><span class="p"><span
class="pre">[</span></span><a class="reference internal"
href="#pydolphinscheduler.core.Task"
title="pydolphinscheduler.core.task.Task"><span class="pre">Task</span>< [...]
@@ -2365,6 +2539,12 @@ object tries to communicate with Java gateway server.</p>
<dd><p>Get attribute process_definition.</p>
</dd></dl>
+<dl class="py property">
+<dt class="sig sig-object py"
id="pydolphinscheduler.tasks.Switch.resource_list">
+<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">resource_list</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">List</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Switch.resource_list" title="Permalink to this
definition"></a></dt>
+<dd><p>Get task define attribute <cite>resource_list</cite>.</p>
+</dd></dl>
+
<dl class="py property">
<dt class="sig sig-object py" id="pydolphinscheduler.tasks.Switch.task_params">
<em class="property"><span class="pre">property</span><span class="w">
</span></em><span class="sig-name descname"><span
class="pre">task_params</span></span><em class="property"><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span
class="pre">Dict</span></em><a class="headerlink"
href="#pydolphinscheduler.tasks.Switch.task_params" title="Permalink to this
definition"></a></dt>
@@ -2456,6 +2636,18 @@ attribute <cite>_task_custom_attr</cite> due to avoid
attribute cover.</p>
</dd></dl>
+<dl class="py class">
+<dt class="sig sig-object py" id="pydolphinscheduler.constants.ResourceKey">
+<em class="property"><span class="pre">class</span><span class="w">
</span></em><span class="sig-prename descclassname"><span
class="pre">pydolphinscheduler.constants.</span></span><span class="sig-name
descname"><span class="pre">ResourceKey</span></span><a class="reference
internal" href="_modules/pydolphinscheduler/constants.html#ResourceKey"><span
class="viewcode-link"><span class="pre">[source]</span></span></a><a
class="headerlink" href="#pydolphinscheduler.constants.ResourceKey" t [...]
+<dd><p>Bases: <code class="xref py py-class docutils literal
notranslate"><span class="pre">str</span></code></p>
+<p>Constants for key of resource.</p>
+<dl class="py attribute">
+<dt class="sig sig-object py" id="pydolphinscheduler.constants.ResourceKey.ID">
+<span class="sig-name descname"><span class="pre">ID</span></span><em
class="property"><span class="w"> </span><span class="p"><span
class="pre">=</span></span><span class="w"> </span><span
class="pre">'id'</span></em><a class="headerlink"
href="#pydolphinscheduler.constants.ResourceKey.ID" title="Permalink to this
definition"></a></dt>
+<dd></dd></dl>
+
+</dd></dl>
+
<dl class="py class">
<dt class="sig sig-object py" id="pydolphinscheduler.constants.TaskFlag">
<em class="property"><span class="pre">class</span><span class="w">
</span></em><span class="sig-prename descclassname"><span
class="pre">pydolphinscheduler.constants.</span></span><span class="sig-name
descname"><span class="pre">TaskFlag</span></span><a class="reference internal"
href="_modules/pydolphinscheduler/constants.html#TaskFlag"><span
class="viewcode-link"><span class="pre">[source]</span></span></a><a
class="headerlink" href="#pydolphinscheduler.constants.TaskFlag" title="Per
[...]
diff --git a/python/genindex.html b/python/genindex.html
index 2a1325987..82167ffcf 100644
--- a/python/genindex.html
+++ b/python/genindex.html
@@ -1078,10 +1078,12 @@
<h2 id="I">I</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
- <li><a
href="tasks/dependent.html#pydolphinscheduler.tasks.dependent.DependentItem.is_all_task">is_all_task
(pydolphinscheduler.tasks.dependent.DependentItem property)</a>
+ <li><a href="api.html#pydolphinscheduler.constants.ResourceKey.ID">ID
(pydolphinscheduler.constants.ResourceKey attribute)</a>
</li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a
href="tasks/dependent.html#pydolphinscheduler.tasks.dependent.DependentItem.is_all_task">is_all_task
(pydolphinscheduler.tasks.dependent.DependentItem property)</a>
+</li>
<li><a href="api.html#pydolphinscheduler.core.Database.items">items()
(pydolphinscheduler.core.Database method)</a>
</li>
</ul></td>
@@ -1513,6 +1515,40 @@
<h2 id="Q">Q</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a
href="api.html#pydolphinscheduler.core.Engine.query_resource">query_resource()
(pydolphinscheduler.core.Engine method)</a>
+
+ <ul>
+ <li><a
href="api.html#pydolphinscheduler.core.Task.query_resource">(pydolphinscheduler.core.Task
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Condition.query_resource">(pydolphinscheduler.tasks.Condition
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.DataX.query_resource">(pydolphinscheduler.tasks.DataX
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Dependent.query_resource">(pydolphinscheduler.tasks.Dependent
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Flink.query_resource">(pydolphinscheduler.tasks.Flink
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Http.query_resource">(pydolphinscheduler.tasks.Http
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.MR.query_resource">(pydolphinscheduler.tasks.MR
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Procedure.query_resource">(pydolphinscheduler.tasks.Procedure
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Python.query_resource">(pydolphinscheduler.tasks.Python
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Shell.query_resource">(pydolphinscheduler.tasks.Shell
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Spark.query_resource">(pydolphinscheduler.tasks.Spark
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Sql.query_resource">(pydolphinscheduler.tasks.Sql
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.SubProcess.query_resource">(pydolphinscheduler.tasks.SubProcess
method)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Switch.query_resource">(pydolphinscheduler.tasks.Switch
method)</a>
+</li>
+ </ul></li>
+ </ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="api.html#pydolphinscheduler.side.Queue">Queue (class in
pydolphinscheduler.side)</a>
</li>
@@ -1536,8 +1572,42 @@
</ul></li>
<li><a
href="api.html#pydolphinscheduler.core.ProcessDefinition.release_state">release_state
(pydolphinscheduler.core.ProcessDefinition property)</a>
</li>
+ <li><a
href="api.html#pydolphinscheduler.core.Engine.resource_list">resource_list
(pydolphinscheduler.core.Engine property)</a>
+
+ <ul>
+ <li><a
href="api.html#pydolphinscheduler.core.Task.resource_list">(pydolphinscheduler.core.Task
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Condition.resource_list">(pydolphinscheduler.tasks.Condition
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.DataX.resource_list">(pydolphinscheduler.tasks.DataX
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Dependent.resource_list">(pydolphinscheduler.tasks.Dependent
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Flink.resource_list">(pydolphinscheduler.tasks.Flink
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Http.resource_list">(pydolphinscheduler.tasks.Http
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.MR.resource_list">(pydolphinscheduler.tasks.MR
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Procedure.resource_list">(pydolphinscheduler.tasks.Procedure
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Python.resource_list">(pydolphinscheduler.tasks.Python
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Shell.resource_list">(pydolphinscheduler.tasks.Shell
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Spark.resource_list">(pydolphinscheduler.tasks.Spark
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Sql.resource_list">(pydolphinscheduler.tasks.Sql
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.SubProcess.resource_list">(pydolphinscheduler.tasks.SubProcess
property)</a>
+</li>
+ <li><a
href="api.html#pydolphinscheduler.tasks.Switch.resource_list">(pydolphinscheduler.tasks.Switch
property)</a>
+</li>
+ </ul></li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a
href="api.html#pydolphinscheduler.constants.ResourceKey">ResourceKey (class in
pydolphinscheduler.constants)</a>
+</li>
<li><a
href="api.html#pydolphinscheduler.constants.JavaGatewayDefault.RESULT_DATA">RESULT_DATA
(pydolphinscheduler.constants.JavaGatewayDefault attribute)</a>
</li>
<li><a
href="api.html#pydolphinscheduler.constants.JavaGatewayDefault.RESULT_MESSAGE_KEYWORD">RESULT_MESSAGE_KEYWORD
(pydolphinscheduler.constants.JavaGatewayDefault attribute)</a>
diff --git a/python/objects.inv b/python/objects.inv
index fd5963cac..92f46ecc3 100644
Binary files a/python/objects.inv and b/python/objects.inv differ
diff --git a/python/searchindex.js b/python/searchindex.js
index ba23f0830..86bbcf0a8 100644
--- a/python/searchindex.js
+++ b/python/searchindex.js
@@ -1 +1 @@
-Search.setIndex({"docnames": ["api", "cli", "concept", "config",
"howto/index", "howto/remote-submit", "index", "start", "tasks/condition",
"tasks/datax", "tasks/dependent", "tasks/flink", "tasks/func_wrap",
"tasks/http", "tasks/index", "tasks/map_reduce", "tasks/procedure",
"tasks/python", "tasks/shell", "tasks/spark", "tasks/sql", "tasks/sub_process",
"tasks/switch", "tutorial"], "filenames": ["api.rst", "cli.rst", "concept.rst",
"config.rst", "howto/index.rst", "howto/remote-submit.rs [...]
\ No newline at end of file
+Search.setIndex({"docnames": ["api", "cli", "concept", "config",
"howto/index", "howto/remote-submit", "index", "start", "tasks/condition",
"tasks/datax", "tasks/dependent", "tasks/flink", "tasks/func_wrap",
"tasks/http", "tasks/index", "tasks/map_reduce", "tasks/procedure",
"tasks/python", "tasks/shell", "tasks/spark", "tasks/sql", "tasks/sub_process",
"tasks/switch", "tutorial"], "filenames": ["api.rst", "cli.rst", "concept.rst",
"config.rst", "howto/index.rst", "howto/remote-submit.rs [...]
\ No newline at end of file
diff --git a/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.html
b/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.html
index bc9c89c03..fedaed617 100644
--- a/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.html
+++ b/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.html
@@ -130,7 +130,8 @@ deployUser="dolphinscheduler"
<span class="hljs-built_in">export</span> PATH=<span
class="hljs-variable">$HADOOP_HOME</span>/bin:<span
class="hljs-variable">$SPARK_HOME1</span>/bin:<span
class="hljs-variable">$SPARK_HOME2</span>/bin:<span
class="hljs-variable">$PYTHON_HOME</span>/bin:<span
class="hljs-variable">$JAVA_HOME</span>/bin:<span
class="hljs-variable">$HIVE_HOME</span>/bin:<span
class="hljs-variable">$FLINK_HOME</span>/bin:<span
class="hljs-variable">$DATAX_HOME</span>/bin:<span
class="hljs-variable">$PATH</span>
</code></pre>
<h2>初始化数据库</h2>
-<p>DolphinScheduler 元数据存储在关系型数据库中，目前支持 PostgreSQL 和 MySQL，如果使用 MySQL 则需要手动下载
<a href="https://downloads.MySQL.com/archives/c-j/";>mysql-connector-java 驱动</a>
(8.0.16) 并移动到 DolphinScheduler 的 lib目录下（<code>tools/libs/</code>）。下面以 MySQL
为例，说明如何初始化数据库</p>
+<p>DolphinScheduler 元数据存储在关系型数据库中，目前支持 PostgreSQL 和 MySQL，如果使用 MySQL 则需要手动下载
<a href="https://downloads.MySQL.com/archives/c-j/";>mysql-connector-java 驱动</a>
(8.0.16) 并移动到 DolphinScheduler 的每个模块的 libs 目录下
+其中包括 <code>api-server/libs/</code> 和 <code>alert-server/libs</code> 和
<code>master-server/libs</code> 和 <code>worker-server/libs</code>。下面以 MySQL
为例，说明如何初始化数据库</p>
<p>对于mysql 5.6 / 5.7：</p>
<pre><code class="language-shell">mysql -uroot -p
<span class="hljs-meta">
diff --git a/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.json
b/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.json
index a13185fc2..4835bf60b 100644
--- a/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.json
+++ b/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.json
@@ -1,6 +1,6 @@
{
"filename": "pseudo-cluster.md",
- "__html": "<h1>伪集群部署</h1>\n<p>伪集群部署目的是在单台机器部署 DolphinScheduler
服务，该模式下master、worker、api server 都在同一台机器上</p>\n<p>如果你是新手，想要体验 DolphinScheduler
的功能，推荐使用<a
href=\"standalone.md\">Standalone</a>方式体检。如果你想体验更完整的功能，或者更大的任务量，推荐使用<a
href=\"pseudo-cluster.md\">伪集群部署</a>。如果你是在生产中使用，推荐使用<a
href=\"cluster.md\">集群部署</a>或者<a
href=\"kubernetes.md\">kubernetes</a></p>\n<h2>前置准备工作</h2>\n<p>伪分布式部署
DolphinScheduler 需要有外部软件的支持</p>\n<ul>\n<li>JDK：下载<a
href=\"https://www.oracle.com/technetwork/java/javase/dow [...]
+ "__html": "<h1>伪集群部署</h1>\n<p>伪集群部署目的是在单台机器部署 DolphinScheduler
服务，该模式下master、worker、api server 都在同一台机器上</p>\n<p>如果你是新手，想要体验 DolphinScheduler
的功能，推荐使用<a
href=\"standalone.md\">Standalone</a>方式体检。如果你想体验更完整的功能，或者更大的任务量，推荐使用<a
href=\"pseudo-cluster.md\">伪集群部署</a>。如果你是在生产中使用，推荐使用<a
href=\"cluster.md\">集群部署</a>或者<a
href=\"kubernetes.md\">kubernetes</a></p>\n<h2>前置准备工作</h2>\n<p>伪分布式部署
DolphinScheduler 需要有外部软件的支持</p>\n<ul>\n<li>JDK：下载<a
href=\"https://www.oracle.com/technetwork/java/javase/dow [...]
"link":
"/dist/zh-cn/docs/dev/user_doc/guide/installation/pseudo-cluster.html",
"meta": {}
}
\ No newline at end of file
