#NEWLINE# def test_backfill_examples( self ) : #NEWLINE# #INDENT# '\n        Test backfilling example dags\n        ' #NEWLINE# skip_dags = [ 'example_http_operator' , 'example_twitter_dag' ] #NEWLINE# logger = logging . getLogger ( 'BackfillJobTest.test_backfill_examples' ) #NEWLINE# dags = [ dag for dag in self . dagbag . dags . values ( ) if ( ( 'example_dags' in dag . full_filepath ) and ( dag . dag_id not in skip_dags ) ) ] #NEWLINE# for dag in dags : #NEWLINE# #INDENT# dag . clear ( start_date = DEFAULT_DATE , end_date = DEFAULT_DATE ) #NEWLINE# #UNINDENT# for ( i , dag ) in enumerate ( sorted ( dags , key = ( lambda d : d . dag_id ) ) ) : #NEWLINE# #INDENT# logger . info ( '*** Running example DAG #{}: {}' . format ( i , dag . dag_id ) ) #NEWLINE# job = BackfillJob ( dag = dag , start_date = DEFAULT_DATE , end_date = DEFAULT_DATE , ignore_first_depends_on_past = True ) #NEWLINE# job . run ( )