Conversation
This is not yet wired up to CI
Fix leak in redisAI.tensorToFlatList method
* Fix valgrind failure on Redis 6.2 * More fixes
* added json example to docs * added json-avg.py * Update examples.md Co-authored-by: Guy Korland <[email protected]>
* fix unstable test * initialize runId to NULL * increase max idle time to avoid failures on mac * Fix tests
* fix unstable valgrind test * review fixes
* Add null record type * make NullRecord singelton * remove special record * init NullRecord * update apis * make NullRecord a special record * rename IS_SPECIAL_RECORD to IS_SINGLETON
|
|
||
| def __enter__(self): | ||
| self.stream_server = gevent.server.StreamServer(('localhost', 10000), self._handle_conn) | ||
| self.port = random.randint(10000,20000) |
There was a problem hiding this comment.
blacklist: Standard pseudo-random generators are not suitable for security/cryptographic purposes.
(at-me in a reply with help or ignore)
| counter = conn.get('counter') | ||
| time.sleep(0.1) | ||
| env.assertTrue(False, message='Counter reached 3 while not expected') | ||
| except Exception as e: |
There was a problem hiding this comment.
try_except_pass: Try, Except, Pass detected.
(at-me in a reply with help or ignore)
| async def coro(r): | ||
| await asyncio.sleep(5) | ||
|
|
||
| GB('ShardsIDReader').foreach(coro).run() No newline at end of file |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| global mutex | ||
| mutex = MyMutex() | ||
|
|
||
| GB('CommandReader').map(publish).register(trigger='MSG_PUBLISH') |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| global mutex | ||
| mutex = MyMutex() | ||
|
|
||
| GB('CommandReader').map(publish).register(trigger='MSG_PUBLISH1') |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| execute('set', 's_count{%s}' % hashtag(), c, 'EX', '5') | ||
| return c | ||
|
|
||
| GB('CommandReader').map(CountStudents).register(trigger='COUNT_STUDENTS', mode='async_local') |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| return c | ||
| return AsyncCountStudents() | ||
|
|
||
| GB('CommandReader').map(CountStudents).register(trigger='COUNT_STUDENTS1', mode='sync') |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| new_args = r[1:] + ['_last_modified_', t] | ||
| return call_next(*new_args) | ||
|
|
||
| GB('CommandReader').map(my_hset).register(hook='hset', mode='sync') No newline at end of file |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| execute('hincrby', r[1], '_times_modified_', 1) | ||
| return call_next(*r[1:]) | ||
|
|
||
| GB('CommandReader').map(my_hset).register(hook='hset', mode='sync') |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| new_args = r[1:] + ['_last_modified_', t] | ||
| return call_next(*new_args) | ||
|
|
||
| GB('CommandReader').map(my_hset).register(hook='hset', keyprefix='person', mode='sync') No newline at end of file |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| @@ -0,0 +1,7 @@ | |||
| import json | |||
|
|
|||
| gb = GB() | |||
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| import json | ||
|
|
||
| gb = GB() | ||
| gb.map(lambda r: json.loads(execute('json.get', r['key'], '$'))) # read the json |
There was a problem hiding this comment.
Unbound name: Name execute is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| execute('SET', k, x) # set key to new value | ||
|
|
||
| # Event handling function registration | ||
| gb = GearsBuilder() |
There was a problem hiding this comment.
Unbound name: Name GearsBuilder is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| @@ -0,0 +1 @@ | |||
| GB().foreach(lambda x: log('key %s was fetched and missed' % x['key'])).register(eventTypes=['keymiss'], mode="async_local") No newline at end of file | |||
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| @@ -0,0 +1 @@ | |||
| GB().foreach(lambda x: log('key %s was fetched and missed' % x['key'])).register(eventTypes=['keymiss'], mode="async_local") No newline at end of file | |||
There was a problem hiding this comment.
Unbound name: Name log is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| data = conn.get(key) | ||
| execute('set', key, data) | ||
|
|
||
| GB().foreach(fetch_data).register(eventTypes=['keymiss'], mode="async_local") No newline at end of file |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
| execute('set', key, data) | ||
| override_reply(data) | ||
|
|
||
| GB().foreach(fetch_data).register(commands=['get'], eventTypes=['keymiss'], mode="async_local") No newline at end of file |
There was a problem hiding this comment.
Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)
|
This pull request introduces 2 alerts when merging 93e6bf7 into 1fd850c - view on LGTM.com new alerts:
|
This reverts commit d32b261.
No description provided.