def clear_task_instances(tis,
                         session,
                         activate_dag_runs=True,
                         dag=None,
                         ):