How to use the funcx.sdk.config.write_option function in funcx
To help you get started, we’ve selected a few funcx examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
funcx-faas / funcX / funcx / sdk / utils / auth.py View on Github 
def _store_config(token_response):
"""
Store the tokens on disk.
Args:
token_response (OAuthTokenResponse): Response from a token request
"""
tkn = token_response.by_resource_server
funcx_at = tkn['funcx_service']['access_token']
funcx_rt = tkn['funcx_service']['refresh_token']
funcx_at_expires = tkn['funcx_service']['expires_at_seconds']
write_option(FUNCX_RT_OPTNAME, funcx_rt)
write_option(FUNCX_AT_OPTNAME, funcx_at)
write_option(FUNCX_AT_EXPIRES_OPTNAME, funcx_at_expires)def _store_config(token_response):
"""
Store the tokens on disk.
Args:
token_response (OAuthTokenResponse): Response from a token request
"""
tkn = token_response.by_resource_server
funcx_at = tkn['funcx_service']['access_token']
funcx_rt = tkn['funcx_service']['refresh_token']
funcx_at_expires = tkn['funcx_service']['expires_at_seconds']
write_option(FUNCX_RT_OPTNAME, funcx_rt)
write_option(FUNCX_AT_OPTNAME, funcx_at)
write_option(FUNCX_AT_EXPIRES_OPTNAME, funcx_at_expires)def _store_config(token_response):
"""
Store the tokens on disk.
Args:
token_response (OAuthTokenResponse): Response from a token request
"""
tkn = token_response.by_resource_server
funcx_at = tkn['funcx_service']['access_token']
funcx_rt = tkn['funcx_service']['refresh_token']
funcx_at_expires = tkn['funcx_service']['expires_at_seconds']
write_option(FUNCX_RT_OPTNAME, funcx_rt)
write_option(FUNCX_AT_OPTNAME, funcx_at)
write_option(FUNCX_AT_EXPIRES_OPTNAME, funcx_at_expires)funcx
Globus Compute: High Performance Function Serving for Science
Package Health Score
58 / 100Popular funcx functions
- funcx.__version__
- funcx.endpoint.utils.MDP
- funcx.endpoint.utils.zhelpers.dump
- funcx.executor.parsl.app.errors.ParslError
- funcx.executor.parsl.app.futures.DataFuture
- funcx.executor.parsl.dataflow.error.DataFlowException
- funcx.executor.parsl.dataflow.states.States
- funcx.executor.parsl.executors.errors.ExecutorError
- funcx.executor.parsl.launchers.launchers.Launcher
- funcx.executor.parsl.providers.error.ExecutionProviderException
- funcx.executors.high_throughput.container_sched.naive_scheduler
- funcx.executors.high_throughput.funcx_manager.Manager
- funcx.executors.high_throughput.interchange.Interchange
- funcx.sdk.client.FuncXClient
- funcx.sdk.config.lookup_option
- funcx.sdk.config.safeprint
- funcx.sdk.config.write_option
- funcx.serialize.base.fxPicker_shared
- funcx.serialize.FuncXSerializer
- funcx.set_file_logger