common.source
SourceInfo Objects
class SourceInfo(NamedTuple)
Runtime information on the source/resource
set_current_pipe_name
def set_current_pipe_name(name: str) -> None
Set pipe name in current thread
unset_current_pipe_name
def unset_current_pipe_name() -> None
Unset pipe name in current thread
get_current_pipe_name
def get_current_pipe_name() -> str
When executed from withing dlt.resource decorated function, gets pipe name associated with current thread.
Pipe name is the same as resource name for all currently known cases. In some multithreading cases, pipe name may be not available.