Skip to content

Merge master to 1.2#702

Merged
gkorland merged 100 commits into1.2from
merge_master_to_1.2
Jan 31, 2022
Merged

Merge master to 1.2#702
gkorland merged 100 commits into1.2from
merge_master_to_1.2

Conversation

@MeirShpilraien
Copy link

No description provided.

Meir Shpilraien (Spielrein) and others added 30 commits February 11, 2021 11:08
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)
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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:
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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')
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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')
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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')
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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')
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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')
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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()
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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()
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

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
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Unbound name: Name GB is used but not defined in the current scope.
(at-me in a reply with help or ignore)

@lgtm-com
Copy link

lgtm-com bot commented Jan 31, 2022

This pull request introduces 2 alerts when merging 93e6bf7 into 1fd850c - view on LGTM.com

new alerts:

  • 1 for Unused import
  • 1 for Variable defined multiple times

@gkorland gkorland merged commit d32b261 into 1.2 Jan 31, 2022
@gkorland gkorland deleted the merge_master_to_1.2 branch January 31, 2022 19:14
MeirShpilraien pushed a commit that referenced this pull request Jan 31, 2022
gkorland pushed a commit that referenced this pull request Jan 31, 2022
@chayim chayim mentioned this pull request Aug 21, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.