Commit a956c0e
authored
v1.0.0 release (#5)
* change: migrate `immutable` to airfly.utils
* add: v1 Task interface
* add: Task._get_taskid
* refine: docstring
* add: Task._to_varname
* add: Task._get_attributes
* fix: type hint
* add: Task._resolve_operator
* add: Task._to_ast
* add: TaskPair._to_ast
* change: TaskTree.from_module interface
* add: TaskTree._collect_taskclass
* add: TaskTree._collect_taskpairs
* add: TaskTree.from_module
* add: TaskTree.to_source
* add: TaskTree._build_header
* add: TaskTree.to_dag
* change: import ast types from asttrs
* fix: get attributes from TaskAttribute
* change: classmethod by staticmethod
* add: Literal
* add: issubclass_by_qualname
* change: replace issubclass by issubclass_by_qualname
* add: refs and aliases in Literal
* add: Param
* change: _get_taskid, _to_varname can be overrided
* add: _build_dag_body
* add: _build_dag_context
* change: unify return type as List[asttrs.stmt]
* update: examples
* change: cannot support lambda
* add: ParamDep and ParamContext
* add: _build_includes
* add: to_dag
* change: rename ParamDep to Param
* change: typing of Param
* change: rename _import_ast to _dep_ast
* change: refactoring ParamContext
* change: resolve conflict import name
* change: naming
* add: _find_alias_without_conflict
* add: _should_exclude in TaskTree
* change: public v1 objects
* refactor: cli
* delete: outdated files
* update: version to 1.0.0
* update: examples
* update: README
* update: test cases
* update: test cases
* add: pytest-mock
* fix: if op_class is a type in Task._resolve_operator
* refactor: cli module
* refactor: load_module_by_name
* change: remove load_module_by_name
* update: asttrs to 1.0.1
* fix: insert ast module from python file
* change: test examples dag
* change: use importlib to import module
* add: python 3.11 and 3.12 into github action
* add: TaskGroup
* fix: reference paranet_group by Name, not Constant
* add: task_group support in Task
* add: task_group support in TaskTree._build_dag_body
* change: revert task_group, derive task_group from task_id
* add: TaskTree._build_task_group
* add: --task-class to CLI argument
* fix: property error
* fix: dag_params error
* add: unit tests for Task._get_attributes
* change: upstream/downstream is iterable
* add: generate task group test template
* add: loguru
* add: logging and little refactoring
* add: support Literal
* fix: Literal handler in Param._target_ast
* change: make order of group_ids consistent
* change: import params' dependencies in dag context
* add: Literal._to_ast
* add: Literal._dep_ast and unit tests
* update: examples
* add: example for demo
* add: 3.11 and 3.12 to classifiers
* update: README
* add: docstring for --task-class
* delete: poetry.lock
* change: avoid building cmd by splitting string
* update: asttrs to 1.3.0
* update: README
* add: task_group argument on cli
* update: README1 parent da83059 commit a956c0e
File tree
32 files changed
+2627
-1853
lines changed- .github/workflows
- examples
- bash_operator
- complex
- python_operator
- tutorial
- src/airfly
- _vendor
- cli
- model
- tests/_gutt/airfly
- cli
- model
32 files changed
+2627
-1853
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
21 | | - | |
| 21 | + | |
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
| |||
0 commit comments