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 e6a030df4 Automated deployment:
599a349d789c45946bc350521dda94150b67d196
e6a030df4 is described below
commit e6a030df4a8893316cbeddeeda3de33a3cd81742
Author: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jul 13 05:10:10 2022 +0000
Automated deployment: 599a349d789c45946bc350521dda94150b67d196
---
.../pydolphinscheduler/core/process_definition.html | 14 ++++++++++++++
python/api.html | 7 +++++--
python/searchindex.js | 2 +-
3 files changed, 20 insertions(+), 3 deletions(-)
diff --git a/python/_modules/pydolphinscheduler/core/process_definition.html
b/python/_modules/pydolphinscheduler/core/process_definition.html
index ddf32ab82..692c1404b 100644
--- a/python/_modules/pydolphinscheduler/core/process_definition.html
+++ b/python/_modules/pydolphinscheduler/core/process_definition.html
@@ -141,6 +141,9 @@
<span class="sd"> thought Web UI after it :func:`submit` or
:func:`run`. It will create a new project belongs to</span>
<span class="sd"> ``user`` if it does not exists. And when ``project``
exists but project's create do not belongs</span>
<span class="sd"> to ``user``, will grant `project` to ``user``
automatically.</span>
+<span class="sd"> :param resource_list: Resource files required by the
current process definition.You can create and modify</span>
+<span class="sd"> resource files from this field. When the process
definition is submitted, these resource files are also</span>
+<span class="sd"> submitted along with it.</span>
<span class="sd"> """</span>
<span class="c1"># key attribute for identify ProcessDefinition
object</span>
@@ -166,6 +169,7 @@
<span class="s2">"tasks"</span><span class="p">,</span>
<span class="s2">"task_definition_json"</span><span
class="p">,</span>
<span class="s2">"task_relation_json"</span><span
class="p">,</span>
+ <span class="s2">"resource_list"</span><span
class="p">,</span>
<span class="p">}</span>
<span class="k">def</span> <span class="fm">__init__</span><span
class="p">(</span>
@@ -185,6 +189,7 @@
<span class="n">timeout</span><span class="p">:</span> <span
class="n">Optional</span><span class="p">[</span><span
class="nb">int</span><span class="p">]</span> <span class="o">=</span> <span
class="mi">0</span><span class="p">,</span>
<span class="n">release_state</span><span class="p">:</span> <span
class="n">Optional</span><span class="p">[</span><span
class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span
class="n">configuration</span><span class="o">.</span><span
class="n">WORKFLOW_RELEASE_STATE</span><span class="p">,</span>
<span class="n">param</span><span class="p">:</span> <span
class="n">Optional</span><span class="p">[</span><span
class="n">Dict</span><span class="p">]</span> <span class="o">=</span> <span
class="kc">None</span><span class="p">,</span>
+ <span class="n">resource_list</span><span class="p">:</span> <span
class="n">Optional</span><span class="p">[</span><span
class="n">List</span><span class="p">]</span> <span class="o">=</span> <span
class="kc">None</span><span class="p">,</span>
<span class="p">):</span>
<span class="nb">super</span><span class="p">()</span><span
class="o">.</span><span class="fm">__init__</span><span class="p">(</span><span
class="n">name</span><span class="p">,</span> <span
class="n">description</span><span class="p">)</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">schedule</span> <span class="o">=</span> <span
class="n">schedule</span>
@@ -210,6 +215,7 @@
<span class="c1"># TODO how to fix circle import</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">_task_relations</span><span class="p">:</span> <span
class="nb">set</span><span class="p">[</span><span
class="s2">"TaskRelation"</span><span class="p">]</span> <span
class="o">=</span> <span class="nb">set</span><span class="p">()</span> <span
class="c1"># noqa: F821</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">_process_definition_code</span> <span class="o">=</span> <span
class="kc">None</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="k">def</span> <span class="fm">__enter__</span><span
class="p">(</span><span class="bp">self</span><span class="p">)</span> <span
class="o">-></span> <span
class="s2">"ProcessDefinition"</span><span class="p">:</span>
<span class="n">ProcessDefinitionContext</span><span
class="o">.</span><span class="n">set</span><span class="p">(</span><span
class="bp">self</span><span class="p">)</span>
@@ -485,6 +491,14 @@
<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">if</span> <span class="nb">len</span><span
class="p">(</span><span class="bp">self</span><span class="o">.</span><span
class="n">resource_list</span><span class="p">)</span> <span
class="o">></span> <span class="mi">0</span><span class="p">:</span>
+ <span class="k">for</span> <span class="n">res</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="n">gateway</span><span class="o">.</span><span
class="n">entry_point</span><span class="o">.</span><span
class="n">createOrUpdateResource</span><span class="p">(</span>
+ <span class="bp">self</span><span class="o">.</span><span
class="n">_user</span><span class="p">,</span>
+ <span class="n">res</span><span class="o">.</span><span
class="n">name</span><span class="p">,</span>
+ <span class="n">res</span><span class="o">.</span><span
class="n">description</span><span class="p">,</span>
+ <span class="n">res</span><span class="o">.</span><span
class="n">content</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>
<div class="viewcode-block" id="ProcessDefinition.start"><a
class="viewcode-back"
href="../../../api.html#pydolphinscheduler.core.ProcessDefinition.start">[docs]</a>
<span class="k">def</span> <span class="nf">start</span><span
class="p">(</span><span class="bp">self</span><span class="p">)</span> <span
class="o">-></span> <span class="kc">None</span><span class="p">:</span>
diff --git a/python/api.html b/python/api.html
index 22e267092..2ef4c0191 100644
--- a/python/api.html
+++ b/python/api.html
@@ -301,7 +301,7 @@ directly set as python property, so we Override
Task.task_params here.</p>
<dl class="py class">
<dt class="sig sig-object py" id="pydolphinscheduler.core.ProcessDefinition">
-<em class="property"><span class="pre">class</span><span class="w">
</span></em><span class="sig-prename descclassname"><span
class="pre">pydolphinscheduler.core.</span></span><span class="sig-name
descname"><span class="pre">ProcessDefinition</span></span><span
class="sig-paren">(</span><em class="sig-param"><span class="n"><span
class="pre">name</span></span><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span class="n"><span
class="pre">str</span></span></em> [...]
+<em class="property"><span class="pre">class</span><span class="w">
</span></em><span class="sig-prename descclassname"><span
class="pre">pydolphinscheduler.core.</span></span><span class="sig-name
descname"><span class="pre">ProcessDefinition</span></span><span
class="sig-paren">(</span><em class="sig-param"><span class="n"><span
class="pre">name</span></span><span class="p"><span
class="pre">:</span></span><span class="w"> </span><span class="n"><span
class="pre">str</span></span></em> [...]
<dd><p>Bases: <code class="xref py py-class docutils literal
notranslate"><span class="pre">Base</span></code></p>
<p>process definition object, will define process definition attribute, task,
relation.</p>
<p>TODO: maybe we should rename this class, currently use DS object name.</p>
@@ -315,6 +315,9 @@ parameter <code class="docutils literal notranslate"><span
class="pre">project</
thought Web UI after it <a class="reference internal"
href="#pydolphinscheduler.core.ProcessDefinition.submit"
title="pydolphinscheduler.core.ProcessDefinition.submit"><code class="xref py
py-func docutils literal notranslate"><span
class="pre">submit()</span></code></a> or <a class="reference internal"
href="#pydolphinscheduler.core.ProcessDefinition.run"
title="pydolphinscheduler.core.ProcessDefinition.run"><code class="xref py
py-func docutils literal notranslate"><span class="pre">ru [...]
<code class="docutils literal notranslate"><span
class="pre">user</span></code> if it does not exists. And when <code
class="docutils literal notranslate"><span class="pre">project</span></code>
exists but project’s create do not belongs
to <code class="docutils literal notranslate"><span
class="pre">user</span></code>, will grant <cite>project</cite> to <code
class="docutils literal notranslate"><span class="pre">user</span></code>
automatically.</p></li>
+<li><p><strong>resource_list</strong> – Resource files required by the current
process definition.You can create and modify
+resource files from this field. When the process definition is submitted,
these resource files are also
+submitted along with it.</p></li>
</ul>
</dd>
</dl>
@@ -425,7 +428,7 @@ for now, and schedule run will coming soon.
<dl class="py attribute">
<dt class="sig sig-object py"
id="pydolphinscheduler.core.ProcessDefinition._DEFINE_ATTR">
-<span class="sig-name descname"><span
class="pre">_DEFINE_ATTR</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">set</span></em><em class="property"><span class="w"> </span><span
class="p"><span class="pre">=</span></span><span class="w"> </span><span
class="pre">{'_project',</span> <span class="pre">'_tenant',</span> <span
class="pre">'description',</span> <span class="pre">'name',</span> <span
class="pre">'param [...]
+<span class="sig-name descname"><span
class="pre">_DEFINE_ATTR</span></span><em class="property"><span
class="p"><span class="pre">:</span></span><span class="w"> </span><span
class="pre">set</span></em><em class="property"><span class="w"> </span><span
class="p"><span class="pre">=</span></span><span class="w"> </span><span
class="pre">{'_project',</span> <span class="pre">'_tenant',</span> <span
class="pre">'description',</span> <span class="pre">'name',</span> <span
class="pre">'param [...]
<dd></dd></dl>
<dl class="py attribute">
diff --git a/python/searchindex.js b/python/searchindex.js
index b1da0eb99..54838b328 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
