METHOD_0 ( ) { "<AssertPlaceHolder>" ; IDENT_0 . METHOD_1 ( java . lang . String . format ( STRING_0 , org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_3 , org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_4 ) ) ; } METHOD_2 ( org . apache . beam . sdk . IDENT_5 . IDENT_6 ) { com . google . api . services . IDENT_1 . IDENT_7 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_11 IDENT_12 = mock ( IDENT_7 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_11 . class ) ; com . google . api . services . IDENT_1 . model . IDENT_13 IDENT_14 = new com . google . api . services . IDENT_1 . model . METHOD_3 ( ) ; IDENT_14 . METHOD_4 ( ( STRING_1 + ( state . name ( ) ) ) ) ; if ( state == ( org . apache . beam . sdk . IDENT_5 . IDENT_6 . IDENT_15 ) ) { IDENT_14 . METHOD_5 ( org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_4 ) ; } when ( IDENT_16 . get ( eq ( org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_17 ) , eq ( org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_18 ) , eq ( org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_3 ) ) ) . thenReturn ( IDENT_12 ) ; when ( IDENT_12 . execute ( ) ) . thenReturn ( IDENT_14 ) ; org . apache . beam . runners . IDENT_1 . IDENT_19 job = new org . apache . beam . runners . IDENT_1 . METHOD_6 ( org . apache . beam . runners . IDENT_1 . IDENT_20 . create ( options ) , org . apache . beam . runners . IDENT_1 . IDENT_2 . IDENT_3 , options , org . apache . beam . IDENT_21 . IDENT_22 . IDENT_23 . com . google . common . collect . ImmutableMap . of ( ) ) ; return job . METHOD_7 ( org . joda . time . IDENT_24 . METHOD_8 ( 1 ) , null , IDENT_25 , IDENT_25 ) ; }
org . junit . Assert . assertEquals ( IDENT_6 . IDENT_15 , METHOD_2 ( IDENT_6 . IDENT_15 ) )