servicex.utils

Description

Classes

log_adaptor()

Helper method to allow easy mocking.

Functions

clean_linq(q)	Normalize the variables in a qastle expression.
dataset_as_name(sample_name[, title, max_len])	Returns a name that is suitable for a progress bar
default_client_session()	Return a client session per thread.
get_configured_cache_path(config)	From the configuration info return a valid path for us to store our cached files.
on_exception_itr(wait_gen, exception[, ...])
retry_exception_itr(target, wait_gen, ...)
sanitize_filename(fname)	No matter the string given, make it an acceptable filename
stream_status_updates(stream, notifier)	As the transformed status goes by, update the notifier with the new values.
stream_unique_updates_only(stream)	As status goes by, only let through changes
write_query_log(request_id, n_files, n_skip, ...)	Log to a csv file the status of a run.