Skip to content

Commit

Permalink
[doc_push][main] built from 86f4344 (main). Redirects: main -> 0.8.0d…
Browse files Browse the repository at this point in the history 
…ev0.
  • Loading branch information
TorchX CI Runner committed Jul 26, 2024
1 parent 9905812 commit 4bef66b
Show file tree
Hide file tree
Showing 11 changed files with 669 additions and 725 deletions.
Binary file modified 0.8.0dev0/_downloads/00d67ca99480eb8a810baf2dcc8feeff/examples_apps_python.zip
View file
Binary file not shown.
Binary file modified 0.8.0dev0/_downloads/0565b2ee0f8662d1acf800c01d94e038/examples_apps_jupyter.zip
View file
Binary file not shown.
Binary file modified 0.8.0dev0/_downloads/3d78ac59c117d4c58eca135c8ee3f34a/examples_pipelines_python.zip
View file
Binary file not shown.
Binary file modified 0.8.0dev0/_downloads/7e7e4caf540a83f1776a6e62b5c440ff/examples_pipelines_jupyter.zip
View file
Binary file not shown.
265 changes: 129 additions & 136 deletions 0.8.0dev0/custom_components.html
View file

Large diffs are not rendered by default.

423 changes: 187 additions & 236 deletions 0.8.0dev0/custom_components.ipynb
View file

Large diffs are not rendered by default.

28 changes: 14 additions & 14 deletions 0.8.0dev0/pipelines/airflow.html
View file
Original file line number Diff line number Diff line change
Expand Up @@ -529,28 +529,28 @@ <h1>Airflow<a class="headerlink" href="#Airflow" title="Permalink to this headin
<div class="prompt empty docutils container">
</div>
<div class="output_area rendered_html docutils container">
<pre style="white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace"><span style="color: #808000; text-decoration-color: #808000; font-weight: bold">/tmp/ipykernel_4683/454499020.py:</span><span style="color: #808000; text-decoration-color: #808000; font-weight: bold">3</span><span style="color: #808000; text-decoration-color: #808000; font-weight: bold"> RemovedInAirflow3Warning</span><span style="color: #808000; text-decoration-color: #808000">: Param `schedule_interval` is deprecated and will be removed in a future release. Please use `schedule` instead.</span>
<pre style="white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace"><span style="color: #808000; text-decoration-color: #808000; font-weight: bold">/tmp/ipykernel_4696/454499020.py:</span><span style="color: #808000; text-decoration-color: #808000; font-weight: bold">3</span><span style="color: #808000; text-decoration-color: #808000; font-weight: bold"> RemovedInAirflow3Warning</span><span style="color: #808000; text-decoration-color: #808000">: Param `schedule_interval` is deprecated and will be removed in a future release. Please use `schedule` instead.</span>
</pre></div>
</div>
<div class="nboutput nblast docutils container">
<div class="prompt empty docutils container">
</div>
<div class="output_area docutils container">
<div class="highlight"><pre>
[<span class="ansi-blue-fg">2024-07-23T16:54:23.950+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2076} INFO - Dependencies all met for dep_context=non-requeueable deps ti=&lt;TaskInstance: example_python_operator-vxmc43hj9dj2g.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]&gt;
[<span class="ansi-blue-fg">2024-07-23T16:54:23.955+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2076} INFO - Dependencies all met for dep_context=requeueable deps ti=&lt;TaskInstance: example_python_operator-vxmc43hj9dj2g.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]&gt;
[<span class="ansi-blue-fg">2024-07-23T16:54:23.956+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2306} INFO - Starting attempt 1 of 1
[<span class="ansi-blue-fg">2024-07-23T16:54:23.957+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2388} WARNING - cannot record queued_duration for task hello_torchx because previous state change time has not been saved
[<span class="ansi-blue-fg">2024-07-23T16:54:23.966+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2330} INFO - Executing &lt;Task(_PythonDecoratedOperator): hello_torchx&gt; on 2021-09-13 00:00:00+00:00
[<span class="ansi-blue-fg">2024-07-23T16:54:24.227+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2648} INFO - Exporting env vars: AIRFLOW_CTX_DAG_OWNER=&#39;airflow&#39; AIRFLOW_CTX_DAG_ID=&#39;example_python_operator-vxmc43hj9dj2g&#39; AIRFLOW_CTX_TASK_ID=&#39;hello_torchx&#39; AIRFLOW_CTX_EXECUTION_DATE=&#39;2021-09-13T00:00:00+00:00&#39; AIRFLOW_CTX_TRY_NUMBER=&#39;1&#39; AIRFLOW_CTX_DAG_RUN_ID=&#39;manual__2021-09-13T00:00:00+00:00&#39;
[<span class="ansi-blue-fg">2024-07-23T16:54:24.230+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>430} INFO - ::endgroup::
[<span class="ansi-blue-fg">2024-07-23T16:54:24.924+0000</span>] {<span class="ansi-blue-fg">api.py:</span>72} INFO - Tracker configurations: {}
[<span class="ansi-blue-fg">2024-07-23T16:54:24.927+0000</span>] {<span class="ansi-blue-fg">local_scheduler.py:</span>771} INFO - Log directory not set in scheduler cfg. Creating a temporary log dir that will be deleted on exit. To preserve log directory set the `log_dir` cfg option
[<span class="ansi-blue-fg">2024-07-23T16:54:24.928+0000</span>] {<span class="ansi-blue-fg">local_scheduler.py:</span>777} INFO - Log directory is: /tmp/torchx_wh8khrqb
[<span class="ansi-blue-fg">2024-07-26T18:20:31.213+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2076} INFO - Dependencies all met for dep_context=non-requeueable deps ti=&lt;TaskInstance: example_python_operator-dmb5p4pc1x7qkd.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]&gt;
[<span class="ansi-blue-fg">2024-07-26T18:20:31.219+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2076} INFO - Dependencies all met for dep_context=requeueable deps ti=&lt;TaskInstance: example_python_operator-dmb5p4pc1x7qkd.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]&gt;
[<span class="ansi-blue-fg">2024-07-26T18:20:31.219+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2306} INFO - Starting attempt 1 of 1
[<span class="ansi-blue-fg">2024-07-26T18:20:31.221+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2388} WARNING - cannot record queued_duration for task hello_torchx because previous state change time has not been saved
[<span class="ansi-blue-fg">2024-07-26T18:20:31.230+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2330} INFO - Executing &lt;Task(_PythonDecoratedOperator): hello_torchx&gt; on 2021-09-13 00:00:00+00:00
[<span class="ansi-blue-fg">2024-07-26T18:20:31.487+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>2648} INFO - Exporting env vars: AIRFLOW_CTX_DAG_OWNER=&#39;airflow&#39; AIRFLOW_CTX_DAG_ID=&#39;example_python_operator-dmb5p4pc1x7qkd&#39; AIRFLOW_CTX_TASK_ID=&#39;hello_torchx&#39; AIRFLOW_CTX_EXECUTION_DATE=&#39;2021-09-13T00:00:00+00:00&#39; AIRFLOW_CTX_TRY_NUMBER=&#39;1&#39; AIRFLOW_CTX_DAG_RUN_ID=&#39;manual__2021-09-13T00:00:00+00:00&#39;
[<span class="ansi-blue-fg">2024-07-26T18:20:31.489+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>430} INFO - ::endgroup::
[<span class="ansi-blue-fg">2024-07-26T18:20:32.180+0000</span>] {<span class="ansi-blue-fg">api.py:</span>72} INFO - Tracker configurations: {}
[<span class="ansi-blue-fg">2024-07-26T18:20:32.184+0000</span>] {<span class="ansi-blue-fg">local_scheduler.py:</span>771} INFO - Log directory not set in scheduler cfg. Creating a temporary log dir that will be deleted on exit. To preserve log directory set the `log_dir` cfg option
[<span class="ansi-blue-fg">2024-07-26T18:20:32.185+0000</span>] {<span class="ansi-blue-fg">local_scheduler.py:</span>777} INFO - Log directory is: /tmp/torchx_9srq0nff
Hello, TorchX!
[<span class="ansi-blue-fg">2024-07-23T16:54:25.036+0000</span>] {<span class="ansi-blue-fg">python.py:</span>237} INFO - Done. Returned value was: None
[<span class="ansi-blue-fg">2024-07-23T16:54:25.037+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>441} INFO - ::group::Post task execution logs
[<span class="ansi-blue-fg">2024-07-23T16:54:25.042+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>1206} INFO - Marking task as SUCCESS. dag_id=example_python_operator-vxmc43hj9dj2g, task_id=hello_torchx, run_id=manual__2021-09-13T00:00:00+00:00, execution_date=20210913T000000, start_date=20240723T165423, end_date=20240723T165425
[<span class="ansi-blue-fg">2024-07-26T18:20:32.293+0000</span>] {<span class="ansi-blue-fg">python.py:</span>237} INFO - Done. Returned value was: None
[<span class="ansi-blue-fg">2024-07-26T18:20:32.294+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>441} INFO - ::group::Post task execution logs
[<span class="ansi-blue-fg">2024-07-26T18:20:32.299+0000</span>] {<span class="ansi-blue-fg">taskinstance.py:</span>1206} INFO - Marking task as SUCCESS. dag_id=example_python_operator-dmb5p4pc1x7qkd, task_id=hello_torchx, run_id=manual__2021-09-13T00:00:00+00:00, execution_date=20210913T000000, start_date=20240726T182031, end_date=20240726T182032
</pre></div></div>
</div>
<p>If all goes well you should see <code class="docutils literal notranslate"><span class="pre">Hello,</span> <span class="pre">TorchX!</span></code> printed above.</p>
Expand Down
68 changes: 34 additions & 34 deletions 0.8.0dev0/pipelines/airflow.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
"cells": [
{
"cell_type": "markdown",
"id": "f879c95a",
"id": "2a6f91e4",
"metadata": {},
"source": [
"# Airflow\n",
Expand All @@ -18,13 +18,13 @@
{
"cell_type": "code",
"execution_count": 1,
"id": "546f0ed6",
"id": "f7120b7e",
"metadata": {
"execution": {
"iopub.execute_input": "2024-07-23T16:54:23.129907Z",
"iopub.status.busy": "2024-07-23T16:54:23.129682Z",
"iopub.status.idle": "2024-07-23T16:54:23.732699Z",
"shell.execute_reply": "2024-07-23T16:54:23.732038Z"
"iopub.execute_input": "2024-07-26T18:20:30.406386Z",
"iopub.status.busy": "2024-07-26T18:20:30.405985Z",
"iopub.status.idle": "2024-07-26T18:20:30.994975Z",
"shell.execute_reply": "2024-07-26T18:20:30.994396Z"
}
},
"outputs": [],
Expand All @@ -44,7 +44,7 @@
},
{
"cell_type": "markdown",
"id": "71b094c2",
"id": "613d30e6",
"metadata": {},
"source": [
"To launch a TorchX job from Airflow you can create a Airflow Python task to\n",
Expand All @@ -56,13 +56,13 @@
{
"cell_type": "code",
"execution_count": 2,
"id": "20f71c19",
"id": "8269e0ec",
"metadata": {
"execution": {
"iopub.execute_input": "2024-07-23T16:54:23.735887Z",
"iopub.status.busy": "2024-07-23T16:54:23.735385Z",
"iopub.status.idle": "2024-07-23T16:54:23.740145Z",
"shell.execute_reply": "2024-07-23T16:54:23.739508Z"
"iopub.execute_input": "2024-07-26T18:20:30.998077Z",
"iopub.status.busy": "2024-07-26T18:20:30.997615Z",
"iopub.status.idle": "2024-07-26T18:20:31.002915Z",
"shell.execute_reply": "2024-07-26T18:20:31.002402Z"
}
},
"outputs": [],
Expand Down Expand Up @@ -93,7 +93,7 @@
},
{
"cell_type": "markdown",
"id": "52c86120",
"id": "7cbbcc4a",
"metadata": {},
"source": [
"Once we have the task defined we can put it into a Airflow DAG and run it like\n",
Expand All @@ -103,24 +103,24 @@
{
"cell_type": "code",
"execution_count": 3,
"id": "cd983551",
"id": "c6870f54",
"metadata": {
"execution": {
"iopub.execute_input": "2024-07-23T16:54:23.742636Z",
"iopub.status.busy": "2024-07-23T16:54:23.742234Z",
"iopub.status.idle": "2024-07-23T16:54:25.050516Z",
"shell.execute_reply": "2024-07-23T16:54:25.049946Z"
"iopub.execute_input": "2024-07-26T18:20:31.005226Z",
"iopub.status.busy": "2024-07-26T18:20:31.005031Z",
"iopub.status.idle": "2024-07-26T18:20:32.307500Z",
"shell.execute_reply": "2024-07-26T18:20:32.306924Z"
}
},
"outputs": [
{
"data": {
"text/html": [
"<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\"><span style=\"color: #808000; text-decoration-color: #808000; font-weight: bold\">/tmp/ipykernel_4683/454499020.py:</span><span style=\"color: #808000; text-decoration-color: #808000; font-weight: bold\">3</span><span style=\"color: #808000; text-decoration-color: #808000; font-weight: bold\"> RemovedInAirflow3Warning</span><span style=\"color: #808000; text-decoration-color: #808000\">: Param `schedule_interval` is deprecated and will be removed in a future release. Please use `schedule` instead.</span>\n",
"<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\"><span style=\"color: #808000; text-decoration-color: #808000; font-weight: bold\">/tmp/ipykernel_4696/454499020.py:</span><span style=\"color: #808000; text-decoration-color: #808000; font-weight: bold\">3</span><span style=\"color: #808000; text-decoration-color: #808000; font-weight: bold\"> RemovedInAirflow3Warning</span><span style=\"color: #808000; text-decoration-color: #808000\">: Param `schedule_interval` is deprecated and will be removed in a future release. Please use `schedule` instead.</span>\n",
"</pre>\n"
],
"text/plain": [
"\u001b[1;33m/tmp/ipykernel_4683/\u001b[0m\u001b[1;33m454499020.py\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m3\u001b[0m\u001b[1;33m RemovedInAirflow3Warning\u001b[0m\u001b[33m: Param `schedule_interval` is deprecated and will be removed in a future release. Please use `schedule` instead.\u001b[0m\n"
"\u001b[1;33m/tmp/ipykernel_4696/\u001b[0m\u001b[1;33m454499020.py\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m3\u001b[0m\u001b[1;33m RemovedInAirflow3Warning\u001b[0m\u001b[33m: Param `schedule_interval` is deprecated and will be removed in a future release. Please use `schedule` instead.\u001b[0m\n"
]
},
"metadata": {},
Expand All @@ -130,92 +130,92 @@
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:23.950+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2076} INFO\u001b[0m - Dependencies all met for dep_context=non-requeueable deps ti=<TaskInstance: example_python_operator-vxmc43hj9dj2g.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]>\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.213+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2076} INFO\u001b[0m - Dependencies all met for dep_context=non-requeueable deps ti=<TaskInstance: example_python_operator-dmb5p4pc1x7qkd.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]>\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:23.955+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2076} INFO\u001b[0m - Dependencies all met for dep_context=requeueable deps ti=<TaskInstance: example_python_operator-vxmc43hj9dj2g.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]>\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.219+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2076} INFO\u001b[0m - Dependencies all met for dep_context=requeueable deps ti=<TaskInstance: example_python_operator-dmb5p4pc1x7qkd.hello_torchx manual__2021-09-13T00:00:00+00:00 [None]>\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:23.956+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2306} INFO\u001b[0m - Starting attempt 1 of 1\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.219+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2306} INFO\u001b[0m - Starting attempt 1 of 1\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:23.957+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2388} WARNING\u001b[0m - cannot record queued_duration for task hello_torchx because previous state change time has not been saved\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.221+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2388} WARNING\u001b[0m - cannot record queued_duration for task hello_torchx because previous state change time has not been saved\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:23.966+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2330} INFO\u001b[0m - Executing <Task(_PythonDecoratedOperator): hello_torchx> on 2021-09-13 00:00:00+00:00\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.230+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2330} INFO\u001b[0m - Executing <Task(_PythonDecoratedOperator): hello_torchx> on 2021-09-13 00:00:00+00:00\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:24.227+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2648} INFO\u001b[0m - Exporting env vars: AIRFLOW_CTX_DAG_OWNER='airflow' AIRFLOW_CTX_DAG_ID='example_python_operator-vxmc43hj9dj2g' AIRFLOW_CTX_TASK_ID='hello_torchx' AIRFLOW_CTX_EXECUTION_DATE='2021-09-13T00:00:00+00:00' AIRFLOW_CTX_TRY_NUMBER='1' AIRFLOW_CTX_DAG_RUN_ID='manual__2021-09-13T00:00:00+00:00'\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.487+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m2648} INFO\u001b[0m - Exporting env vars: AIRFLOW_CTX_DAG_OWNER='airflow' AIRFLOW_CTX_DAG_ID='example_python_operator-dmb5p4pc1x7qkd' AIRFLOW_CTX_TASK_ID='hello_torchx' AIRFLOW_CTX_EXECUTION_DATE='2021-09-13T00:00:00+00:00' AIRFLOW_CTX_TRY_NUMBER='1' AIRFLOW_CTX_DAG_RUN_ID='manual__2021-09-13T00:00:00+00:00'\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:24.230+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m430} INFO\u001b[0m - ::endgroup::\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:31.489+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m430} INFO\u001b[0m - ::endgroup::\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:24.924+0000\u001b[0m] {\u001b[34mapi.py:\u001b[0m72} INFO\u001b[0m - Tracker configurations: {}\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:32.180+0000\u001b[0m] {\u001b[34mapi.py:\u001b[0m72} INFO\u001b[0m - Tracker configurations: {}\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:24.927+0000\u001b[0m] {\u001b[34mlocal_scheduler.py:\u001b[0m771} INFO\u001b[0m - Log directory not set in scheduler cfg. Creating a temporary log dir that will be deleted on exit. To preserve log directory set the `log_dir` cfg option\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:32.184+0000\u001b[0m] {\u001b[34mlocal_scheduler.py:\u001b[0m771} INFO\u001b[0m - Log directory not set in scheduler cfg. Creating a temporary log dir that will be deleted on exit. To preserve log directory set the `log_dir` cfg option\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:24.928+0000\u001b[0m] {\u001b[34mlocal_scheduler.py:\u001b[0m777} INFO\u001b[0m - Log directory is: /tmp/torchx_wh8khrqb\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:32.185+0000\u001b[0m] {\u001b[34mlocal_scheduler.py:\u001b[0m777} INFO\u001b[0m - Log directory is: /tmp/torchx_9srq0nff\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"Hello, TorchX!\n",
"[\u001b[34m2024-07-23T16:54:25.036+0000\u001b[0m] {\u001b[34mpython.py:\u001b[0m237} INFO\u001b[0m - Done. Returned value was: None\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:32.293+0000\u001b[0m] {\u001b[34mpython.py:\u001b[0m237} INFO\u001b[0m - Done. Returned value was: None\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:25.037+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m441} INFO\u001b[0m - ::group::Post task execution logs\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:32.294+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m441} INFO\u001b[0m - ::group::Post task execution logs\u001b[0m\n"
]
},
{
"name": "stdout",
"output_type": "stream",
"text": [
"[\u001b[34m2024-07-23T16:54:25.042+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m1206} INFO\u001b[0m - Marking task as SUCCESS. dag_id=example_python_operator-vxmc43hj9dj2g, task_id=hello_torchx, run_id=manual__2021-09-13T00:00:00+00:00, execution_date=20210913T000000, start_date=20240723T165423, end_date=20240723T165425\u001b[0m\n"
"[\u001b[34m2024-07-26T18:20:32.299+0000\u001b[0m] {\u001b[34mtaskinstance.py:\u001b[0m1206} INFO\u001b[0m - Marking task as SUCCESS. dag_id=example_python_operator-dmb5p4pc1x7qkd, task_id=hello_torchx, run_id=manual__2021-09-13T00:00:00+00:00, execution_date=20210913T000000, start_date=20240726T182031, end_date=20240726T182032\u001b[0m\n"
]
}
],
Expand Down Expand Up @@ -247,7 +247,7 @@
},
{
"cell_type": "markdown",
"id": "a446901f",
"id": "c8fb7440",
"metadata": {},
"source": [
"If all goes well you should see `Hello, TorchX!` printed above.\n",
Expand Down
Loading

0 comments on commit 4bef66b

Please sign in to comment.