16
16
17
17
18
18
def _get_message (
19
- coin : str , currency : str , increase_in_percentage : float , * , indicator : dict [str , int | float ]
19
+ coin : str ,
20
+ currency : str ,
21
+ increase_in_percentage : float ,
22
+ frequency_in_minutes : int ,
23
+ * ,
24
+ indicator : dict [str , int | float ],
20
25
) -> str | None :
21
26
key , value = next (iter (indicator .items ()))
22
27
@@ -30,26 +35,28 @@ def _get_message(
30
35
ratio_abs = abs (ratio )
31
36
32
37
if ratio_abs < increase_in_percentage :
33
- logger .info (f"No new { key .upper ()} Alerts for { coin } . Ratio is { ratio } ." )
38
+ logger .info (
39
+ f"No new { key .upper ()} alerts for coin:{ coin } ; frequency_in_minutes:{ frequency_in_minutes } ratio: { ratio } ."
40
+ )
34
41
return None
35
42
36
43
verb = "increased" if ratio > 0 else "decreased"
37
- return f"The { key .upper ()} { verb } { ratio_abs :.2f} %"
44
+ return f"The { key .upper ()} { verb } { ratio_abs :.2f} % in the last { frequency_in_minutes } minute(s) "
38
45
39
46
40
47
@huey .periodic_task (crontab (minute = "*/1" ))
41
48
@huey .lock_task (TASK_LOCK )
42
49
def bullish_or_bearish__1_min ():
43
- task (increase_in_percentage = 1.0 )
50
+ task (increase_in_percentage = 1.0 , frequency_in_minutes = 1 )
44
51
45
52
46
53
@huey .periodic_task (crontab (minute = "*/10" ))
47
54
@huey .lock_task (TASK_LOCK )
48
55
def bullish_or_bearish__10_min ():
49
- task (increase_in_percentage = 4.0 )
56
+ task (increase_in_percentage = 4.0 , frequency_in_minutes = 10 )
50
57
51
58
52
- def task (* , increase_in_percentage : float ):
59
+ def task (* , increase_in_percentage : float , frequency_in_minutes : int ):
53
60
name = datetime .today ().date ().strftime ("%Y-%m-%d" )
54
61
55
62
with redis .pipeline () as pipe :
0 commit comments