Running Apache Airflow with the KubernetesExecutor on a multi-node Kubernetes cluster locally

👍 SMASH THE LIKE BUTTON
❤️ SUBSCRIBE TO MY CHANNEL TO STAY UP TO DATE
🏆 THE COURSE : www.udemy.com/course/the-ulti...
(SPECIAL PROMOTION)
🚨 PATREON: / marclamberti Access PATREON ONLY content
Hi Folks!
In this video you are going to discover how to set up Airflow with the Kubernetes Executor on a multi-node Kubernetes cluster locally.
Here is the link to the materials:
marclamberti.com/youtube-mate...
Enjoy!

Пікірлер: 47

  • @arthurcolle2778
    @arthurcolle27782 жыл бұрын

    Here buddy you dropped this: 👑

  • @loudsilence5181
    @loudsilence51813 жыл бұрын

    This is really good, Marc, thnx.

  • @MarcLamberti

    @MarcLamberti

    3 жыл бұрын

    Glad you like it!

  • @loudsilence5181

    @loudsilence5181

    3 жыл бұрын

    @@MarcLamberti do you cover more in depth customization in your udemy courses? Like, how does one figure out what variables are needed for this thing to work as it should?

  • @ajikusbandono
    @ajikusbandono3 жыл бұрын

    very nice article, thanks alot it work for me.

  • @MarcLamberti

    @MarcLamberti

    3 жыл бұрын

    You're welcome!

  • @saverioguzzo6144
    @saverioguzzo61443 жыл бұрын

    hey @Marc! Is there maybe a plan to upgrade this useful material to be relevant for Airflow 2? Thanks

  • @alexkuznicki845
    @alexkuznicki8453 жыл бұрын

    Hi Mark - question on providing credentials/api keys to a specific DAG. Say I need Airlfow to run my python script that reads data from a database, and then pushes something to AWS. I need to store 1) creds for database and 2) for aws (separate from airflow logs bucket). How do you achieve this in this setup you presented?

  • @user-wc6go6rd9o
    @user-wc6go6rd9o5 ай бұрын

    Hi mark - Even port forwarded to 8080 exactly like in the video but unable see the Airflow UI.

  • @iandavidson9761
    @iandavidson97613 жыл бұрын

    Quick reminder, after running your port forwarding command, open a new shell, even backgrounding port forwarding process will prohibit you from reaching page in browser.

  • @raisvaza5413
    @raisvaza54132 жыл бұрын

    Hey Marc. It was a great tutorial but I always failed installing the helm release. It says: timed out waiting for the condition. Is there any work around I can do to solve this? Thank you

  • @tomke92z

    @tomke92z

    Жыл бұрын

    Same here... I enabled debug and I get the following error: "Error: INSTALLATION FAILED: failed post-install: warning: Hook post-install airflow/templates/create-user-job.yaml failed: jobs.batch "airflow-create-user" already exists helm.go:84: [debug] failed post-install: warning: Hook post-install airflow/templates/create-user-job.yaml failed: jobs.batch "airflow-create-user" already exists"

  • @antoniusbonni3601

    @antoniusbonni3601

    Жыл бұрын

    Same. I always got installation failed, tried several times create another yaml file override.yaml but always getting error.

  • @stonecoldcold2941
    @stonecoldcold29413 жыл бұрын

    Hey, is there any way that I could use selenium with apache airflow? I am doing some web scraping using selenium. I dont find any ways to integrate it with airflow. One article I found using docker. Problem is I downloaded airflow using PIP. Can you help me?

  • @MarcLamberti

    @MarcLamberti

    3 жыл бұрын

    Never used Selenium but try your tuto with Docker :) It will be easier btw

  • @samsoneromonsei9368
    @samsoneromonsei93684 ай бұрын

    Do you have rebuild the values.yaml each time you want to deploy a new DAG as an image, I noticed you absolutely mapped the default repository to just one image in the values.yaml. How is this scalable in an environment where you need to constantly deploy multiple dags.

  • @muhammadhusnain974
    @muhammadhusnain9743 жыл бұрын

    @Marc when I run the docker build command, I get this error Step 1/2 : FROM apache/airflow:1.10.10.1-alpha2-python3.7 manifest for apache/airflow:1.10.10.1-alpha2-python3 not found: manifest unknown: manifest unknown Can you please help? what could be the issue?

  • @abhishekchoudhary6073
    @abhishekchoudhary60734 жыл бұрын

    hey marc, lets say I have two machine A and B ...on machine A Kubernetes is running and on B Airflow...so is there any way to send task from airflow to remote cluster lies on A. I know I've to use kubernetesExecutor..but how do I configure it

  • @MarcLamberti

    @MarcLamberti

    4 жыл бұрын

    You can do this either with the Kubernetes Executor or the KubernetesPodOperator. Take a look at the last one ;)

  • @alexkuznicki845
    @alexkuznicki8453 жыл бұрын

    Why did you not use the helm/stable/airflow chart? Just curious becuase I've tried with that one

  • @MarcLamberti

    @MarcLamberti

    3 жыл бұрын

    Cause the current stable airflow chart is not the official one :)

  • @alexkuznicki845

    @alexkuznicki845

    3 жыл бұрын

    @@MarcLamberti Haha got it! Thanks for providing the tutorials by the way very helpful. I will ask one more question in a new comment for other uses who may have the same question.

  • @muhammadhusnain974
    @muhammadhusnain9743 жыл бұрын

    @Marc when I try to login using the username as "admin' as well as the password 'admin' , it gives me error and says, Invalid login. Please try again. Can you please help?

  • @prasadgummadavelli9807
    @prasadgummadavelli98073 жыл бұрын

    can you share steps in github repository??

  • @raefelsayed944
    @raefelsayed9443 жыл бұрын

    How can I access the deployed Airflow on local kubernetes cluster through a local network using IpAddress?

  • @FuzzPiAndFacial

    @FuzzPiAndFacial

    3 жыл бұрын

    You should be able to access via ip double check the port you have set

  • @chanduchama
    @chanduchama3 жыл бұрын

    Hi MarcLamberti, Thanks for creating this video. I couldn't find the materials from the video in the link provided. Can you please upload the repository used in this video?

  • @MarcLamberti

    @MarcLamberti

    3 жыл бұрын

    I just checked, here is the link: marclamberti.com/youtube-materials/

  • @rfrost4708

    @rfrost4708

    3 жыл бұрын

    @@MarcLamberti I can't seem to find any resources on that page. Just some text. Can you confirm once again please.

  • @tribo327
    @tribo3273 жыл бұрын

    I get an error saying: Error: failed to download "airflow/airflow" when I run helm install -f values.yml --kube-context kind-airflow-cluster airflow airflow/airflow I have run helm repo update but that doesn't help. Has anyone else experienced this?

  • @vipulkandivalikar4885

    @vipulkandivalikar4885

    3 жыл бұрын

    Same here. I get the same issue too :(

  • @vipulkandivalikar4885

    @vipulkandivalikar4885

    3 жыл бұрын

    @Mohsin Rafi I was never able to pull an image from my local registry from a K8 pod. However when I uploaded it to a public docker hub registry my pods were able to use that image and run without issues.

  • @cesarvigario

    @cesarvigario

    2 жыл бұрын

    I think the image does not exist. Go to values.yml and change the parameter "defaultAirflowTag" to something like 1.10.10-2-python3.7.

  • @MoonIsCheese
    @MoonIsCheese Жыл бұрын

    I get this error Error: INSTALLATION FAILED: failed post-install: timed out waiting for the condition When entering "helm install -f values.yml --kube-context kind-airflow-cluster airflow airflow/airflow"

  • @doniuppa
    @doniuppa2 жыл бұрын

    Windows version please

  • @vinaykumararigala1728
    @vinaykumararigala17284 жыл бұрын

    Hey, I Have followed the tutorial and was able to get it working with the default image that you have used (apache/airflow:1.10.10.1-alpha2-python3.7) I am trying to get it working with a private registry (nexus). I'd like to know how do we pass the imagepulsecrets in values.yml file. my values.yml looks as follows. # Default airflow repository -- overrides all the specific images below defaultAirflowRepository: myregistry:5100/image # Default airflow tag to deploy defaultAirflowTag: latest registry: myregistry:5100 secretName: secret_created_in_cluster

  • @vinaykumararigala1728

    @vinaykumararigala1728

    4 жыл бұрын

    with the above values.yml i get imagepullbacoff error

  • @kushagraverma7855

    @kushagraverma7855

    4 жыл бұрын

    @@vinaykumararigala1728 check pod logs. There should be some errors. Also am forgetting, there are some changes to be made in values.yaml to enable KubernetesExecutor.

  • @vinaykumararigala1728

    @vinaykumararigala1728

    4 жыл бұрын

    @@kushagraverma7855 the pod is not even coming up actually, I just get a image pull backoff error

  • @daanluttik454
    @daanluttik4543 жыл бұрын

    Hé I found that the link to your chart is not working any more nor do you have any materials in your "link to the materials". You mention that it is based on the "official chart" and that that is not "stable/airflow", but I can't find that chart anywhere either.. Could you provide a reference.

  • @MarcLamberti

    @MarcLamberti

    3 жыл бұрын

    Yes, the official chart is in the repository of apache/airflow under the folder chart. Here: github.com/apache/airflow/tree/master/chart

  • @daanluttik454

    @daanluttik454

    3 жыл бұрын

    @@MarcLamberti Thanks.

  • @marcusaureliusanonymous
    @marcusaureliusanonymous3 жыл бұрын

    helm install --debug -f values.yml --kube-context kind-airflow-cluster airflow airflow/airflow install.go:172: [debug] Original chart version: "" install.go:189: [debug] CHART PATH: /home/tensorflow/.cache/helm/repository/airflow-1.0.0.tgz client.go:255: [debug] Starting delete for "airflow-broker-url" Secret client.go:109: [debug] creating 1 resource(s) client.go:255: [debug] Starting delete for "airflow-fernet-key" Secret client.go:109: [debug] creating 1 resource(s) client.go:255: [debug] Starting delete for "airflow-redis-password" Secret client.go:109: [debug] creating 1 resource(s) client.go:109: [debug] creating 17 resource(s) client.go:109: [debug] creating 1 resource(s) client.go:464: [debug] Watching for changes to Job airflow-create-user with timeout of 5m0s client.go:492: [debug] Add/Modify event for airflow-create-user: ADDED client.go:531: [debug] airflow-create-user: Jobs active: 0, jobs failed: 0, jobs succeeded: 0 Error: failed post-install: timed out waiting for the condition helm.go:81: [debug] failed post-install: timed out waiting for the condition

  • @marcusaureliusanonymous

    @marcusaureliusanonymous

    3 жыл бұрын

    Can Some help me in order to resolve this issue?

  • @marcusaureliusanonymous

    @marcusaureliusanonymous

    3 жыл бұрын

    Delete the cluster and followed your tutorial again and it worked now but not sure why it happened at first place!!!

  • @rodrigoalarcon1154
    @rodrigoalarcon11542 жыл бұрын

    This tutorial is broken, the Helm chart is no longer available