From 9ae2d23f16723b2c6045caa261a9d3ec0b5fdf37 Mon Sep 17 00:00:00 2001
From: Cyril Motte <cyrilmotte4collab@gmail.com>
Date: Tue, 11 Jun 2024 08:48:01 +0200
Subject: [PATCH] add my first dag

---
 .github/dependabot.yml                        |  12 ++++
 .../dags/__pycache__/my_dag.cpython-312.pyc   | Bin 0 -> 1580 bytes
 airflow/dags/my_dag.py                        |  56 ++++++++++++++++++
 airflow/logs/scheduler/latest                 |   2 +-
 4 files changed, 69 insertions(+), 1 deletion(-)
 create mode 100644 .github/dependabot.yml
 create mode 100644 airflow/dags/__pycache__/my_dag.cpython-312.pyc
 create mode 100644 airflow/dags/my_dag.py

diff --git a/.github/dependabot.yml b/.github/dependabot.yml
new file mode 100644
index 0000000..f33a02c
--- /dev/null
+++ b/.github/dependabot.yml
@@ -0,0 +1,12 @@
+# To get started with Dependabot version updates, you'll need to specify which
+# package ecosystems to update and where the package manifests are located.
+# Please see the documentation for more information:
+# https://docs.github.com/github/administering-a-repository/configuration-options-for-dependency-updates
+# https://containers.dev/guide/dependabot
+
+version: 2
+updates:
+ - package-ecosystem: "devcontainers"
+   directory: "/"
+   schedule:
+     interval: weekly
diff --git a/airflow/dags/__pycache__/my_dag.cpython-312.pyc b/airflow/dags/__pycache__/my_dag.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..7f564861ffbb721a41a27cf8bf4711d1faa62446
GIT binary patch
literal 1580
zcma)6O>7%Q6n?X7@2)rgi4)g$5<3bh5V<XJ%ijqqVhRWj0h9yOinMHYrnbqhZDuzl
zt^(?TLnJQclp-#OQ>)~_of}s!Zn>;hL<k`ya?77oDJR~nf0`&4X0^|6zIkuw&G)_W
zZ;6BsIIbMl?yM>Re~ZarXnp7SRRXXL6ezL5Ayq<zFWHhKS7j$sjf8XAjyg(J3H^wz
zI%-u7{iv-uv1$x`<r}E#R7E=?0V7mHtI`<NslFrk_M#&+zMI&I^k%O?HI6YdO|p^Q
z)Q;3ctBDXBJ%=SjEPW13Ar_%yOh1!5ikL#jX=eA*@O$YH%hKE#Y>XvXlBH@g8@(F?
zU}-j1lZ1!o$ctx?O`wy%3^%|f>k@(6xGs<l`8KSR(!{<fxkLi_*1~%wDM)_Q@#?MS
zhi%49uf>B*g_}*Qejdf}c*S(<gD9M9)byCwaM&XfsF*?<P0vD6hC>i0C_G+7vkjZ@
z`PtQeSPcdIiR?-{{k5-%*QXs|lMGR5Q=;<fEdWkBkxsOvESBV8)Z=EO*=W`br$w1<
zEL=b;7m&9_<(}!T8V&01i*5=u)3Vm^>@3h5&4G`^#5Sy!W3<<7JCGf712>esMxgg1
ztOj#~#0qmgqYrdkQTWWv%;{9Q)%MC}gWs`R>t$-z+_KX#@OQr53C0Yo-fFqb2y?^2
zc^(r*DeiSN_rSlD+g|=|`3NG{^!v-l5Xp{g=_fi&6dru=LuxDG$0r^vJc$?m+;e_v
z>KJpt5@s-l#7`o!4c?G;N~kpGktHa}i~C|}U)(k>_J0I?Lijl}LCQE!FP}zq9A7ty
z<{tc!%HIFt!R)tRceP@e7AU<_HvU!d8&eo`S9yz?4ZHI$a;LkV$vtENc}}}lozXR$
z8Q3$7e`(r*YMGu@Uu*Lb%tP|kzD7Z+9k!=onYL}N*o?<9fG5xd>5EK`id|C-7iQ)L
zQqGkmep$rFSFnQ(6xG3Q<!KR`?u9<neQvQd9;kioxKK36_h<91{uOaiM{#AiAeu)-
zO!i`o*o@=f7jUEl0!3Vrmc#M7LMV91XCPx+glB$sF8+cD5hn?2<VE2Pbvf1Ez@|a&
zZt`omAOv*(L31DzLiQl{C%nH0<vl3w!Q_z=BZZ?ZA=8HnD6y^l_w^sWhadk;exH8X
z&rUy#p2$QgAHXbW691Lg|C%cKnHT-S)sv`P(7RgxP=~^m{{t0o_?bDsFpr5vOq{^P
z%#5F(^@{?^=vx{h*;zmTykESINLJs{58|LtcBig(UwX5v-RxGD9&1b8Pe1Ff*xgT@
gCz|v09U|&_8di50+EZ7E|I312Ny@(_qm`WcAB1O=6951J

literal 0
HcmV?d00001

diff --git a/airflow/dags/my_dag.py b/airflow/dags/my_dag.py
new file mode 100644
index 0000000..b312711
--- /dev/null
+++ b/airflow/dags/my_dag.py
@@ -0,0 +1,56 @@
+from airflow import DAG
+from airflow.operators.python import PythonOperator, BranchPythonOperator
+from airflow.operators.bash import BashOperator
+from datetime import datetime
+from random import randint
+
+
+def _choose_best_model(ti):
+        accuracies = ti.xcom_pull(task_ids=[
+                'training_model_A',
+                'training_model_B',
+                'training_model_C'
+        ])
+        best_accuracy = max(accuracies)
+        if (best_accuracy > 8):
+                return 'accurate'
+        return 'inaccurate'
+        
+def _training_model():
+        return randint(1, 10)
+
+with DAG("my_dag", start_date=datetime(2024, 1, 1),
+    schedule_interval="@daily", catchup=False)  as dag:
+
+        training_model_A = PythonOperator(
+            task_id="training_model_A",
+            python_callable=_training_model
+        )
+
+        training_model_B = PythonOperator(
+            task_id="training_model_B",
+            python_callable=_training_model
+        )
+
+        training_model_C = PythonOperator(
+            task_id="training_model_C",
+            python_callable=_training_model
+        )
+
+        choose_best_model = BranchPythonOperator(
+            task_id="choose_best_model",
+            python_callable=_choose_best_model
+        )
+
+        accurate = BashOperator(
+                task_id="accurate",
+                bash_command="echo 'accurate'"
+        )
+
+        inaccurate = BashOperator(
+                task_id="inaccurate",
+                bash_command="echo 'inaccurate'"
+        )
+
+        
+        [training_model_A, training_model_B, training_model_C] >> choose_best_model >> [accurate, inaccurate]
\ No newline at end of file
diff --git a/airflow/logs/scheduler/latest b/airflow/logs/scheduler/latest
index 51e6f68..a394665 120000
--- a/airflow/logs/scheduler/latest
+++ b/airflow/logs/scheduler/latest
@@ -1 +1 @@
-2024-05-26
\ No newline at end of file
+2024-06-11
\ No newline at end of file