Commit a6ea12fd authored by 唐香港's avatar 唐香港

Update clear_tasks_container_logs.py

parent 1ae1756e
...@@ -9,7 +9,7 @@ import os,logging ...@@ -9,7 +9,7 @@ import os,logging
default_args = { default_args = {
'owner': 'tangxianggang', 'owner': 'tangxianggang',
'depends_on_past': False, 'depends_on_past': False,
'start_date': datetime.now() - timedelta(days=1), 'start_date': datetime.now() - timedelta(minutes=1445),
'retries': 2, 'retries': 2,
'retry_delay': timedelta(seconds=5) 'retry_delay': timedelta(seconds=5)
} }
...@@ -17,11 +17,11 @@ default_args = { ...@@ -17,11 +17,11 @@ default_args = {
dag = DAG( dag = DAG(
dag_id='clear_tasks_container_logs', dag_id='clear_tasks_container_logs',
default_args=default_args, default_args=default_args,
schedule_interval=timedelta(minutes=720) schedule_interval=timedelta(minutes=1445)
) )
def clear_worker_logs(): def clear_worker_logs():
dt = datetime.now() - timedelta(minutes=720) dt = datetime.now() - timedelta(minutes=1445)
time_str = dt.strftime('%Y-%m-%d') time_str = dt.strftime('%Y-%m-%d')
cmd = 'rm -rf /opt/bitnami/airflow/logs/*/*/%s*' % (time_str) cmd = 'rm -rf /opt/bitnami/airflow/logs/*/*/%s*' % (time_str)
logging.info('exec cmd : ' + cmd) logging.info('exec cmd : ' + cmd)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment