Dear ALL??
Support Linux SSH Task ???? Linux SSH ???? ???????????????????????????????????????????????????????? Shell ??????Shell ???????????????????????????????????? Worker ???????????????????????????????????????????????????? Shell ?????????????????????????????????????????????????????????????????? For example, in my project, the workflow's tasks want to execute shell scripts where are in different server's different directory. When worker execute these shell scripts, it must use the same user to login these server. Also, the worker can get the executing state of these server. We can config these server 's host,user and password. SSH Task is very useful for most user SSH ???????????????????????????? ?????????????????????? Shell ???????????????????????????????????????????????????????????????? Worker?????????? Worker ?????????????????????????????????????????????????????????????? In dolphinscheduler, the most executing tasks are in different servers who are not workers. These servers also have their different fixed services. We just have to pass different parameters to schedule these shell scripts to execute. Python has a module to execute ssh script Python ??????????????????????????SSH Shell ???? Python ??????????????????????SSH Shell??????????????????????paramiko?? Python has a module that can execute SSH Shell script. It's paramiko. Others ???????? ???????????????????????????????????????????????????????????????????? I found this described in previous feature, but it was relatively simple. Feature URL ???????????? Shell Task ?????????????????????????????????????????????????????????????????????? In addition, it is very inconvenient for me to perform remote tasks through Shell Task. Here is my script. I don't know if there's a better way. sshpass -p 'password' ssh user@host echo 'ssh success' echo 'Hello World' -> /home/dolphinscheduler/test/hello.txt echo 'end' Support dummy task like airflow ?????? Airflow ???????????? ???????????????????????????????? DAG ??????DAG ?????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????? Dummy Task????????????????????????????????????????????????????????????????????????AirFlow??????????????DummyOperator???????? For example, in my project, it has a productized DAG file. The file contains different modules, some of which are interdependent and some of which are not. When customers purchase different modules, we need to set some tasks as dummy tasks, which some modules are not purchased and the purchased module is not dependent. Because of this setting, these dummy tasks are actually not executed. The benefits of this setup are product unity and diagram integrity. In airflow, these task execute by dummy operator. ** Realize ????????** Dummy Task ???????????????????????????????????????????????????????????????? dummy ?????????????????????????? Dummy Task?? Dummy Task is easy to realize, but it need to use with other different tasks. When the task's executed type is set to dummy type, the task are executed as a dummy task and the real task is not executed. ????????????????????????????????????Fork?????????????????????????????????????????????????????????? By the way??I already realize these two features in my fork branch. Whether the follow-up release can be supported
