Custom Operator with TaskFlow #39333
Unanswered
zander1976
asked this question in
Q&A
Replies: 1 comment 1 reply
-
Ohh, I am using Alma linux 8.9 with Python3.9 and Airflow 2.8 |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Good Afternoon,
I apologize is this has been covered before. I did search and review all the airflow code and astro code and no luck. I am sure it's something silly that I am doing.
I created a simple operator:
and it seems to work fine with:
I wanted to register an @task.spssm like the following:
I then created the wrapper class and registration class:
All the code can be found in dags/custom/SPSSMOperator.py and I do have an empty init.py file in that directory.
I keep getting:
AttributeError: task decorator 'spssm' not found
Thank you so much for your help. SPSSM is a scripting language that runs to produce statistical data.
Ben
Beta Was this translation helpful? Give feedback.
All reactions