METHOD_0 ( ) { org . apache . beam . sdk . IDENT_0 p = org . apache . beam . sdk . IDENT_0 . create ( options ) ; org . apache . beam . sdk . values . IDENT_1 < java . lang . Integer > IDENT_2 = p . apply ( org . apache . beam . sdk . IDENT_3 . IDENT_4 . of ( 1 , 2 , 3 ) ) ; org . apache . beam . sdk . testing . IDENT_5 . that ( IDENT_2 ) . METHOD_1 ( 1 , 2 , 3 ) ; org . apache . beam . runners . IDENT_6 . IDENT_7 IDENT_8 = org . mockito . Mockito . mock ( org . apache . beam . runners . IDENT_6 . IDENT_7 . class ) ; when ( IDENT_8 . METHOD_2 ( ) ) . thenReturn ( IDENT_9 . IDENT_10 ) ; when ( IDENT_8 . METHOD_3 ( ) ) . thenReturn ( STRING_0 ) ; when ( IDENT_8 . METHOD_4 ( ) ) . thenReturn ( STRING_1 ) ; when ( IDENT_8 . METHOD_5 ( any ( org . joda . time . IDENT_11 . class ) , any ( org . apache . beam . runners . IDENT_6 . util . IDENT_12 . IDENT_13 . class ) ) ) . METHOD_6 ( ( IDENT_14 ) -> { com . google . api . services . IDENT_6 . model . IDENT_15 message = new com . google . api . services . IDENT_6 . model . METHOD_7 ( ) ; message . METHOD_8 ( STRING_2 ) ; message . METHOD_9 ( org . apache . beam . runners . IDENT_6 . util . IDENT_16 . METHOD_10 ( org . joda . time . IDENT_17 . now ( ) ) ) ; message . METHOD_11 ( STRING_3 ) ; ( ( org . apache . beam . runners . IDENT_6 . util . IDENT_12 . IDENT_13 ) ( IDENT_14 . METHOD_12 ( ) [ 1 ] ) ) . process ( java . util . Arrays . asList ( message ) ) ; return IDENT_9 . IDENT_10 ; } ) ; org . apache . beam . runners . IDENT_6 . IDENT_18 IDENT_19 = org . mockito . Mockito . mock ( org . apache . beam . runners . IDENT_6 . IDENT_18 . class ) ; when ( IDENT_19 . run ( any ( org . apache . beam . sdk . IDENT_0 . class ) ) ) . thenReturn ( IDENT_8 ) ; org . apache . beam . runners . IDENT_6 . IDENT_20 runner = org . apache . beam . runners . IDENT_6 . IDENT_20 . METHOD_13 ( options , IDENT_21 ) ; when ( IDENT_21 . METHOD_14 ( anyString ( ) ) ) . thenReturn ( METHOD_15 ( true , true ) ) ; "<AssertPlaceHolder>" ; } run ( org . apache . beam . model . IDENT_22 . v1 . IDENT_23 . IDENT_24 , org . apache . beam . IDENT_25 . grpc . IDENT_26 . io . grpc . IDENT_27 . IDENT_28 ) { org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_31 . LOG . trace ( STRING_4 , org . apache . beam . model . IDENT_22 . v1 . IDENT_23 . IDENT_24 . class . METHOD_16 ( ) , request ) ; java . lang . String IDENT_32 = request . METHOD_17 ( ) ; try { org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_33 IDENT_34 = IDENT_35 . get ( IDENT_32 ) ; if ( IDENT_34 == null ) { java . lang . String IDENT_36 = java . lang . String . format ( STRING_5 , IDENT_32 ) ; org . apache . beam . IDENT_25 . grpc . IDENT_26 . io . grpc . IDENT_37 exception = Status . IDENT_38 . METHOD_18 ( IDENT_36 ) . METHOD_19 ( ) ; IDENT_39 . METHOD_20 ( exception ) ; return ; } try { org . apache . beam . runners . core . IDENT_40 . graph . IDENT_41 . validate ( IDENT_34 . pipeline ( ) ) ; } catch ( java . lang . Exception e ) { org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_31 . LOG . warn ( STRING_6 , e ) ; IDENT_39 . METHOD_20 ( new org . apache . beam . IDENT_25 . grpc . IDENT_26 . io . grpc . METHOD_21 ( Status . IDENT_42 . METHOD_22 ( e ) ) ) ; return ; } org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_43 IDENT_14 = IDENT_44 . invoke ( IDENT_34 . pipeline ( ) , IDENT_34 . options ( ) , request . METHOD_23 ( ) ) ; java . lang . String IDENT_45 = IDENT_14 . getId ( ) ; IDENT_14 . METHOD_24 ( ( state ) -> { if ( ! ( org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_43 . METHOD_25 ( state ) ) ) { return ; } java . lang . String IDENT_46 = IDENT_47 . get ( IDENT_32 ) ; IDENT_47 . remove ( IDENT_32 ) ; if ( ( IDENT_48 ) != null ) { try { IDENT_48 . accept ( IDENT_46 ) ; } catch ( e ) { org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_31 . LOG . error ( STRING_7 , IDENT_46 , org . apache . beam . runners . IDENT_29 . IDENT_30 . e ) ; } } } ) ; IDENT_14 . start ( ) ; IDENT_49 . put ( IDENT_45 , IDENT_14 ) ; org . apache . beam . model . IDENT_22 . v1 . IDENT_23 . IDENT_50 response = org . apache . beam . model . IDENT_22 . v1 . IDENT_23 . IDENT_50 . METHOD_26 ( ) . METHOD_27 ( IDENT_45 ) . build ( ) ; IDENT_39 . METHOD_28 ( response ) ; IDENT_39 . METHOD_29 ( ) ; } catch ( org . apache . beam . IDENT_25 . grpc . IDENT_26 . io . grpc . METHOD_21 e ) { org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_31 . LOG . warn ( STRING_8 , e ) ; IDENT_39 . METHOD_20 ( e ) ; } catch ( java . lang . Exception e ) { java . lang . String IDENT_36 = java . lang . String . format ( STRING_9 , IDENT_32 ) ; org . apache . beam . runners . IDENT_29 . IDENT_30 . IDENT_31 . LOG . error ( IDENT_36 , e ) ; IDENT_39 . METHOD_20 ( Status . IDENT_51 . METHOD_22 ( e ) . METHOD_19 ( ) ) ; } }
org . junit . Assert . assertEquals ( IDENT_8 , runner . run ( p , IDENT_19 ) )