Передайте несколько команд параметру command
, разделенному &&
, например:
command='(command1) && (command2) && (command3)'
Таким образом, полный код выглядит так:
t_docker = DockerOperator(
task_id='docker_command',
image='bde2020/spark-master:latest',
api_version='auto',
auto_remove=True,
command='(python a.py) && (echo "done") && (mkdir /mydirectory) && (echo "directory created"))',
network_mode='bridge'
)