def set_pipeline_timeout(strategy, user, *args, **kwargs):
 if (strategy.request and (not user)):
  strategy.request.session.set_expiry(strategy.setting('PIPELINE_TIMEOUT', 600))

def set_pipeline_timeout ( strategy , user , * args , ** kwargs ) : if ( strategy . request and ( not user ) ) : strategy . request . session . set_expiry ( strategy . setting ( 'PIPELINE_TIMEOUT' , 600 ) )
set a short session timeout while the pipeline runs .