This commit is contained in:
@@ -1,4 +1,11 @@
|
|||||||
from .private import format_filesize, async_retry, retry, async_test, ExceptionHandlerOutcome
|
from .private import (
|
||||||
|
format_filesize,
|
||||||
|
async_retry,
|
||||||
|
retry,
|
||||||
|
async_test,
|
||||||
|
ExceptionHandlerOutcome,
|
||||||
|
tmpdir
|
||||||
|
)
|
||||||
from .maybe import Maybe
|
from .maybe import Maybe
|
||||||
|
|
||||||
__all__ = [
|
__all__ = [
|
||||||
@@ -7,5 +14,6 @@ __all__ = [
|
|||||||
'retry',
|
'retry',
|
||||||
'async_test',
|
'async_test',
|
||||||
'ExceptionHandlerOutcome',
|
'ExceptionHandlerOutcome',
|
||||||
'Maybe'
|
'Maybe',
|
||||||
|
'tmpdir'
|
||||||
]
|
]
|
||||||
|
@@ -1,4 +1,6 @@
|
|||||||
import math
|
import math
|
||||||
|
from tempfile import TemporaryDirectory
|
||||||
|
from pathlib import Path
|
||||||
from enum import Enum, auto
|
from enum import Enum, auto
|
||||||
from typing import Callable
|
from typing import Callable
|
||||||
from time import sleep
|
from time import sleep
|
||||||
@@ -17,7 +19,6 @@ def format_filesize(size: int) -> str:
|
|||||||
return '%.2f ' % (size / math.pow(1024, counter)) + _size_uoms[counter]
|
return '%.2f ' % (size / math.pow(1024, counter)) + _size_uoms[counter]
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
class ExceptionHandlerOutcome(Enum):
|
class ExceptionHandlerOutcome(Enum):
|
||||||
THROW = auto()
|
THROW = auto()
|
||||||
CONTINUE = auto()
|
CONTINUE = auto()
|
||||||
@@ -75,8 +76,23 @@ def async_retry(
|
|||||||
|
|
||||||
return wrapper
|
return wrapper
|
||||||
|
|
||||||
|
|
||||||
def async_test(coro):
|
def async_test(coro):
|
||||||
def wrapper(*args, **kwargs):
|
def wrapper(*args, **kwargs):
|
||||||
with Runner() as runner:
|
with Runner() as runner:
|
||||||
runner.run(coro(*args, **kwargs))
|
runner.run(coro(*args, **kwargs))
|
||||||
|
|
||||||
|
return wrapper
|
||||||
|
|
||||||
|
|
||||||
|
def tmpdir(argument_name='tmpdir'):
|
||||||
|
def wrapper(fun):
|
||||||
|
def result(*args, **kwargs):
|
||||||
|
with TemporaryDirectory() as temp_dir:
|
||||||
|
fun(*args, **kwargs, **{
|
||||||
|
argument_name: Path(temp_dir)
|
||||||
|
})
|
||||||
|
|
||||||
|
return result
|
||||||
|
|
||||||
return wrapper
|
return wrapper
|
Reference in New Issue
Block a user