(task)
| 836 | |
| 837 | |
| 838 | def get_task_schemas(task): |
| 839 | current_work_dir = os.path.dirname(__file__) |
| 840 | with open(current_work_dir + '/pipeline_schema.json', 'r') as f: |
| 841 | schema = json.load(f) |
| 842 | if task in schema: |
| 843 | return schema[task] |
| 844 | return None |
| 845 | |
| 846 | |
| 847 | if __name__ == '__main__': |
no test coverage detected
searching dependent graphs…