migration: undoing ship/src.bowl change, adding logging to imports

This commit is contained in:
Hunter Miller 2022-11-30 16:46:47 -06:00
parent 173b641df4
commit de1cdcefbb
2 changed files with 8 additions and 8 deletions

View File

@ -186,11 +186,10 @@
++ on-agent
|= [=wire =sign:agent:gall]
^- (quip card _this)
~& src.bol
=^ cards state
?+ wire [- state]:(on-agent:def wire sign)
[%pyre *] (take-pyre:gc t.wire sign)
[%gladio @ ~] (take-migrate:gc (slav %p i.t.wire) sign)
[%gladio @ ~] (take-migrate:gc sign)
::
[%try-rejoin @ *]
?> ?=(%poke-ack -.sign)
@ -237,7 +236,6 @@
^- (quip card _state)
=^ cards-1=(list card) wait
~(migrate-start gladio bol)
~& wait
=/ cards-2=(list card)
%+ turn ~(tap in wait)
|= =ship
@ -256,18 +254,18 @@
[%pass / %pyre leaf/"{<wire>} failed" u.p.sign]~
::
++ take-migrate
|= [=ship =sign:agent:gall]
|= =sign:agent:gall
^- (quip card _state)
~& [%migrating ship src.bol]
~& migrating/src.bol
?: ?=(%poke-ack -.sign)
`state
:_ state(wait (~(del in wait) ship))
:_ state(wait (~(del in wait) src.bol))
^- (list card)
%+ welp (~(migrate-ship gladio bol) ship)
%+ welp (~(migrate-ship gladio bol) src.bol)
?: ?=(%kick -.sign) :: TODO: check queued watches don't get kicked
*(list card)
:_ *(list card)
[%pass /gladio/(scot %p ship) %agent [ship %groups] %leave ~]
[%pass /gladio/(scot %p src.bol) %agent [src.bol %groups] %leave ~]
::
++ peek-group
|= rid=resource

View File

@ -144,6 +144,7 @@
heap-flags=(flag-importer %graph-validator-link)
diary-flags=(flag-importer %graph-validator-publish)
==
~& [%to-import chat-flags]
=/ setup=(list card)
%+ welp (migrate-ship our.bowl)
:* (poke-our %groups group-import+!>(imports))
@ -176,6 +177,7 @@
%. ~(key by links)
=- ~(uni in -)
(~(uni in ~(key by chats)) ~(key by diarys))
~& [%importing ~(key by chats)]
%+ welp
%+ turn ~(tap in graph-flags)
|= =flag:i