Comments (3)
This sounds like a great idea to me. 👍
from dag-factory.
@dinigo have you ever started writing code for this? This would be very useful indeed.
I'm facing similar situation with kubernetes pod operator where all arguments are kubernetes python api objects
from dag-factory.
@vitoravancini, We were using our own coupled config-to-DAG library. For standardization purposes we decided to go with a FOSS solution such as dag-factory
one (thanks @ajbosco !).
I suspect it only requires changing where config is loaded
config: Dict[str, Any] = yaml.load(
stream=open(config_filepath, "r", encoding="utf-8"),
- Loader=yaml.FullLoader,
+ Loader=yaml.UnsafeLoader,
)
This way you can make use of types other than the mandatory ones in yaml.
Mi strong opinion is that, since you are the owner of the config, you can use the said "UnsafeLoader". In my opinion this name is not accurate, since most part of people managing yaml files are not doing so in an unsupervised way from the network. So this reference to a possible injection attack is out of context.
If you where so kind as to create a PR and write a couple of tests following the above examples that will create a working env for us to collaborate
from dag-factory.
Related Issues (20)
- Not able to generate dynamic dags more than 200 HOT 1
- Upgrade to Airflow 2.5.0: No module named airflow.providers.cncf.kubernetes.backcompat.pod / airflow.contrib.kubernetes HOT 1
- new feature after airflow 2.4.0 - can dag-factory support Datasets?
- Basic Example DAG is not loading HOT 1
- Dag not shown in UI
- Dynamic task mapping using Xcoms HOT 1
- dag-factory does not support operator inheriting from KubernetesPodOperator
- More documentation is required, Please.
- support for ShortCircuitOperator
- ExternalTaskSensor does not work as expected HOT 1
- variables_as_arguments results in a large number of variable queries
- Build dynamic tasks in my DAG (view of separate tasks)
- Support for CronTriggerTimetable? HOT 1
- Using Airflow Variables in YML files HOT 2
- Use SSH operator in DAG-Factory to run bash command in other server
- Pick path based on AIRFLOW_HOME directory
- Not able to set `on_failure_callback` in default args
- Init containers is not converted to V1 kubernetes models HOT 2
- Use mounts / DockerOperator
- Variable is not getting substituted in impersonation_chain parameter of GKEStartPodOperator
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from dag-factory.