Same image is cached when POST download method is used

Check List
Thanks for considering to open an issue. Before you submit your issue, please confirm these boxes are checked.

[ x ] I have read the wiki page and cheat sheet, but there is no information I need.
[ x ] I have searched in existing issues, but did not find a same one.
[ ] I want to report a problem instead of asking a question. It'd better to use kingfisher tag in Stack Overflow to ask a question.

Issue Description
Cashing same image when POST request with body is used
What
I am using POST method request for downloading images. So images has same url and function addDownloadTask in file ImageDownloader.swift is reuse existing task for downloading image instead of creating new one, because of implemented logic below:
private func addDownloadTask(
        context: DownloadingContext,
        callback: SessionDataTask.TaskCallback
    ) -> DownloadTask
    {
        // Ready to start download. Add it to session task manager (`sessionHandler`)
        let downloadTask: DownloadTask
        if let existingTask = sessionDelegate.task(for: context.url) {
            downloadTask = sessionDelegate.append(existingTask, url: context.url, callback: callback)
        } else {
            let sessionDataTask = session.dataTask(with: context.request)
            sessionDataTask.priority = context.options.downloadPriority
            downloadTask = sessionDelegate.add(sessionDataTask, url: context.url, callback: callback)
        }
        return downloadTask
    }

Is it possible to add option  forceCreateDownloadTask which will create new task or extend logic for comparison existing task?

Sorry for the late reply.
This is really a rare use case and it is the first time we receive such a request. I wonder whether it worths adding another option for this a case.
Does this trick work:
Try to append some random hash so it leads to different URL (so you can have another download task) but requesting the same resource:
// Two different download task, but the same resource.
imageView.kf.setImage(with: URL(string: "https://example.com/image.png#123"))
imageView.kf.setImage(with: URL(string: "https://example.com/image.png#456"))


add separate codeowner for split out transformer package

when splitting out the transformer package from the backend package, I did not add a codeowner for the new path
this fixes that

@ColinKerr I'm going to wait for your explicit approval since this marks you as the secondary code owner

@mergifyio update


[Feature Request] Support BIP39 Passphrase

Request to support additional BIP39 passphrase when importing accounts
A BIP39 passphrase is additional to a 12 or 24 word seed, often referred to as a "13th" or "25th word". Adding a passphrase produces an entirely different set of keys from the seed alone.
A seed can be imported into Hiro, but there's currently no option for this additional passphrase, which could be useful for hardware wallet users looking to import their accounts as a last resort recovery method.

This would make Hiro fully compatible with Ledger's full security model.
I support this feature request.

Another request here: https://twitter.com/EgyptianMagicin/status/1628172661149822978

Another thumbs up today from a Discord user:

In case anyone is wondering you can already use a Ledger with passphrase to access additional accounts.
this issue is specifically meant for support when using the wallet in software mode.

Another user looking forward to this feature.


'chunk_size' doesnt work on 'split_documents' function

System Info
langchain: 0.0.208
platform: win 10
python: 3.9.
The warning message is :
'Created a chunk of size 374, which is longer than the specified 100'.
Who can help?
@hwchase17  @eyurtsev
Information

[ ] The official example notebooks/scripts
[X] My own modified scripts

Related Components

[ ] LLMs/Chat Models
[ ] Embedding Models
[ ] Prompts / Prompt Templates / Prompt Selectors
[ ] Output Parsers
[X] Document Loaders
[ ] Vector Stores / Retrievers
[ ] Memory
[ ] Agents / Agent Executors
[X] Tools / Toolkits
[ ] Chains
[ ] Callbacks/Tracing
[ ] Async

Reproduction
Step1: run the code snippets below:
from langchain.document_loaders import TextLoader
from langchain.text_splitter import CharacterTextSplitter
text = '''
Google opens up its AI language model PaLM to challenge OpenAI and GPT-3
Google is offering developers access to one of its most advanced AI language models: PaLM.
The search giant is launching an API for PaLM alongside a number of AI enterprise tools
it says will help businesses “generate text, images, code, videos, audio, and more from
simple natural language prompts.”
PaLM is a large language model, or LLM, similar to the GPT series created by OpenAI or
Meta’s LLaMA family of models. Google first announced PaLM in April 2022. Like other LLMs,
PaLM is a flexible system that can potentially carry out all sorts of text generation and
editing tasks. You could train PaLM to be a conversational chatbot like ChatGPT, for
example, or you could use it for tasks like summarizing text or even writing code.
(It’s similar to features Google also announced today for its Workspace apps like Google
Docs and Gmail.)'''
with open('test.txt','w') as f:
f.write(text)

loader = TextLoader('test.txt')
docs_from_file = loader.load()
print(docs_from_file)
text_splitter1 = CharacterTextSplitter(chunk_size=100,chunk_overlap=20)
docs = text_splitter1.split_documents(docs_from_file)
print(docs)
print(len(docs))
Step 2: then it cannot split the text as expected
Expected behavior
It should split the doc as expected size as chunk_size.

sounds good


Feat/custom oauth2 header

Summary
Extended the oauth2 plugin to have a new parameter "auth_header_name" which by default is "authorization" but can be overwritten to any custom header name when enabling oauth2 for an api
Full changelog

kong/plugins/oauth2/schema.lua
kong/plugins/oauth2/access.lua

Test cases

spec/03-plugins/26-oauth2/01-schema_spec.lua
spec/03-plugins/26-oauth2/03-access_spec.lua

Currently Kong uses the "Authorization" header to check for oauth2 tokens, the changes in this request enables kong to verify tokens in the custom headers configured when enabling the Oauth2 plugin on an api.
eg:
curl -X POST http://localhost:8001/apis/test-api/plugins
--data "name=oauth2"
--data "config.enable_authorization_code=true"
--data "config.scopes=email"
--data "config.auth_header_name=Custom-Auth-Header"
If the config.auth_header_name is not set then the default header checked is "Authorization"

@Tieske incorporated the suggested changes, please let me know your thoughts on them

Merged manually, adjusting the commit message. Thank you @supraja93!

:+1:

@Tieske @hishamhm  Thank you 👍


Global - Investigate wether changing your name causes the status icon to no longer be green

Task: There is a possability that changing your name will cause your online status indicator to no longer be green. This ticket is to investigate and jot down whatever notes we have from our findings

Some notes from what I found when testing:

It does appear like when User A changes their name, online indicator will change from Green to Grey.

https://user-images.githubusercontent.com/93608357/223881572-a2605438-fed4-4e24-aeca-a1b1991b9c28.mov

Second thing is, it seems like when you first login your friend will appear offline (until after 60 seconds then it realizes) but if your friend sends you a message before that 60 seconds their indicator will change from offline to green immediately

https://user-images.githubusercontent.com/93608357/223881993-10d441ce-f809-4c69-abfc-59e12a9d353c.mov

A recent PR will refresh friends every 60 seconds. Receiving a message likely rerendered the page to show the status change hence why the second one is the way it was.
For the first one, that is client side in uplink. Likely not grabbing or updating status after the name change. Does it still show offline when you send something?

This is now fixed.


Handle tab completion for commands and names

client bound: http://wiki.vg/Protocol#Tab-Complete http://prismarinejs.github.io/minecraft-data/?d=protocol#toClient_tab_complete
server bound: http://wiki.vg/Protocol#Tab-Complete_2 http://prismarinejs.github.io/minecraft-data/?d=protocol#toServer_tab_complete

Maybe let commands make their own tab competition (array of possibilities)... Maybe also merge with section? (e.g. /we  shows possible commands or sub-sections)

Yeah that would do it (add a complete:function(alreadyWritten) {return completed;} option in commands)
I think we need to experiment a bit to know what would be convenient, but that complete option would probably work. (maybe it's possible to have a default complete for the most simple commands)

How do we want to do this? We could have a complete() {} next to parse and action, but... It seems like it would be difficult to parse that. Should we just hope for the best and use that?

I think such a complete function would take the incomplete parameters (everything after /command) and return what to complete with, or nothing if it cannot guess.
For example it could guess the player name used in /tp
Mostly need a serv.completePlayerName that would take an incomplete name and figure out the complete one.
In order to do that, the simple (but inefficient if lot of players are connected) is looping on the player list and checking whether the username starts with the provided string.
The efficient solution would be building a https://en.wikipedia.org/wiki/Trie of the username, but we probably don't need that for now.

It might interesting to see if there's something convenient in https://www.npmjs.com/browse/keyword/trie though

https://www.npmjs.com/package/triecomplete seems pretty good


! Fixed a few minor issues on install/uninstall

Signed-off-by: jdarwood007<EMAIL_ADDRESS>

This Partially fixes #37


Listen for and handle DCN events, persist DCN events

Could we put a screenshot in? That would raise my confidence?
I don’t have the files for this in the event simulator, but we could put them in there and I could show you how

I made a bunch of changes. In general I think blockchain people want to see hexadecimal, so we are going to give it to them. I added a test that exercises the encoding stuff too, take a look.

I don't think the test is perfect, but would you like to add the expiration event/response to it and we call this PR good?

Actually, I want to add the mint time. I'll do that.


ability to load plugins

Ability to load and unload plugins during runtime

:clock1: 10h

:clock1: 2h

🕐 2h


Ability to Migrate Environment to Another Region

Power Platform Admin Center should provide the ability to initiate a request to migrate a CDS environment to another region (i.e. Canada to US East). Alternatively, this should be something that MSFT Support should be able to handle on request. The current solution is to re-create the environment in the new region is not particularly practical, and this scenario does come up from time to time.

Document Details
⚠ Do not edit this section. It is required for docs.microsoft.com ➟ GitHub issue linking.

ID: 4df941f8-45db-4cdd-c7d1-363febdd42dc
Version Independent ID: cc136308-8205-6516-e05e-1c8e5a94f3c0
Content: Regions overview  Microsoft Docs - Power Platform
Content Source: power-platform/admin/regions-overview.md
Service: power-platform
GitHub Login: @jimholtz
Microsoft Alias: jimholtz

@berellax
Thanks for your feedback. For product-related feedback, visit https://ideas.powerapps.com.


Collision Box is Misaligned

Describe the bug
The collision box for all sign blocks are slightly misaligned in three out of four directions. The issue is minor, but could cause minor collisions.
Fixing this may require optimizing the code for rotatable blocks, which has not worked so far.
To Reproduce
Steps to reproduce the behavior:

Select any sign block
Place block
Hover mouse over collision box to view misalignment.

Expected behavior
The collision box should align with the shape of the sign blocks.
Additional Information (please complete the following information):

Minecraft Version: 1.16.x
Mod Version: 0.1.2, 0.2.0
Forge Version: N/A

This issue has been partially resolved in the latest commit. However, it is still misaligned in one of four directions.

This issue was fixed entirely in the latest commit (version v0.3.0). Please note v0.3.0-beta still contains this bug, and you should update.


chore(release): Autobump agent service version (1.0.12)

Automated PR

Merging into release notes branch doc/agent-service-rn-v1.0.12


First release of CodeSigning

Contributing to the Azure SDK
Please see our CONTRIBUTING.md if you are not familiar with contributing to this repository or have questions.
For specific information about pull request etiquette and best practices, see this section.

/azp run prepare-pipelines

API change check
APIView has identified API level changes in this PR and created following API reviews.
Azure.ResourceManager.CodeSigning

Depend on https://github.com/Azure/azure-rest-api-specs/pull/24501


app script editor addon publised using API/script

Hello Team:
My company run a google doc addon which is sure an appscript project.Now I can use Clasp(which is a node.js tool) to push and make deployment .but when it comes to publish on chrome web store .I have to do it by hand.
1.select specific version
2.click "update web store draft"
3.click "publish changes"
Can these step be taken automatically? I try to find some API,but it is not useful for me.

Unfortunately there's no API for the publishing side of things at the moment. Chrome web store did have an API for publishing, but there's no equivalent for the G Suite Marketplace.

Marking as wontfix since it's unlikely that this will be automatable any time soon.


volume and title arguments on Client.upload_session should be optional

The API doesn't require these, as chapters not having titles or volumes is a common occurance (think for example web toons. There's also an issue that if you specify a volume, and every other language doesn't bother to, your translations are all cobbled up on the last page, since "No volume" chapters all come first. Real annoying).
However the upload_session enforces you to specify them.
It is possible to pass an empty string for title, but the regex for volume denies empty strings.
On this note, a chapter may also have no scanlation groups, so it being optional could also make sense, but this one I'm fine with.
That said, I'm having some issues with uploading in general, but I'll file a separate issue for this once I double checked my stuff.
Also fyi, since you mention in your readme that you're not able to test uploads, there is a test manga here:
https://mangadex.org/title/f9c33607-9180-4ba6-b85c-e4b5faee7192/official-test-manga
where you're allowed to just upload junk to.

Hey, thanks for the heads up.
I'll get to work on fixing this for you, it's real simple with the current state of the code base. I'll also set up a local-only test bench for uploading now that I know about the test manga!

I have now located another bug whilst testing, so perhaps this is related to the issue you were having!
The documentation for committing chapters says it responds with a general GetChapterResponse, so {"id": ..., "type": "chapter", ...}
However in my testing we are actually getting a GetSingleChapterResponse, which is {"result": "ok", "type": "entity", "data": GetChapterResponse}.
I will now amend this.

Fixed in 12d1cf4f97913204000ebfb5b384ae5f3a061f47.

Thank you! And glad I could help a bit.
Yes, that was the issue I was having :)
Works now with your changes.


Get/drop all now works fixes #20

Current coverage is 19.66%

Merging #39 into master will decrease coverage by -1.24% as of 5df6e25

@@            master     #39   diff @@
======================================
  Files           31      31
  Stmts          837     890    +53
  Branches       126     136    +10
  Methods          0       0
======================================
  Hit            175     175
  Partial          0       0
- Missed         662     715    +53

Review entire Coverage Diff as of 5df6e25

Powered by Codecov. Updated on successful CI builds.


treewide: use use lib.optionalAttrs instead of 'then {}'

Description of changes

Things done

Built on platform(s)

[ ] x86_64-linux
[ ] aarch64-linux
[ ] x86_64-darwin
[ ] aarch64-darwin

[ ] For non-Linux: Is sandbox = true set in nix.conf? (See Nix manual)
[ ] Tested, as applicable:

NixOS test(s) (look inside nixos/tests)
and/or package tests
or, for functions and "core" functionality, tests in lib/tests or pkgs/test
made sure NixOS tests are linked to the relevant packages

[ ] Tested compilation of all packages that depend on this change using nix-shell -p nixpkgs-review --run "nixpkgs-review rev HEAD". Note: all changes have to be committed, also see nixpkgs-review usage
[ ] Tested basic functionality of all binary files (usually in ./result/bin/)
23.11 Release Notes (or backporting 23.05 Release notes)

[ ] (Package updates) Added a release notes entry if the change is major or breaking
[ ] (Module updates) Added a release notes entry if the change is significant
[ ] (Module addition) Added a release notes entry if adding a new NixOS module

[x] Fits CONTRIBUTING.md.

thanks for your good and thorough reviews :+1:

Aaand again - broke evaluation and is blocking channels.
$ nix eval -f. lispPackages.clsql.outPath
error: 'tail' called on an empty list
[...]


APPS-803 Sonatype Nexus publishing setup readme.

From discussion, agreed to merge documentation of current process
Jiras to publish to GitHub packages https://jira.internal.dnanexus.com/browse/APPS-809 , https://jira.internal.dnanexus.com/browse/APPS-808


The link to the "Emulating 'self types' using Java Generics to simpli…

…fy fluent API implementation" blog post is dead, so replace it with a link to the Internet Archive's most recent scrape of the blog post.
Inspired by: https://github.com/joel-costigliola/assertj-core/commit/207611e4a475a6e7ee7a1afa4b6025973022fb57

Thanks


Error popup is not cleared when switching function containers

Steps to reproduce:

Browse App Services
Open function app A and have it hit an error that shows the red popup.
Open function app B.

Expected result: Error popup from function app A disappears after selecting function app B.
Actual result: Error popup remains

@paulbatum, can you please close it. no-repro


v6 quote & v6 swap

I've modified a bit to work with v6 endpoint.

Thank you very much for this PR. I apologize it took so long to merge it


change tab back to the first one when click to different navigation tab

I want to reset the select index back to the first tab (create tab in the screen shot) when I change the bottom navigation tab and go back. it tried func reloadMenu() as well as pagingViewController.select(index: 0), they both not working. here is my code
extension IndexReferralViewControler: UITabBarControllerDelegate {
func tabBarController(_ tabBarController: UITabBarController, didSelect viewController: UIViewController) {
let vc = UIApplication.topViewController(controller: viewController) as? IndexReferralViewControler
if vc != self {
[pagingViewController.reloadMenu()

    }
}

}

reloadMenu will keep the currently selected index, so you need to use pagingViewController.select(index: 0). I'm not sure why that shouldn't work. Are you sure the method is actually being called?

I am also facing same issue. have you solve your issue. if yes, then please help me
I call the select method in viewWillAppear. and my code confirm executes. It select first page controller, but menu indicator are not moved to first page it remains on previous selected page.
Thanks.

Hi @lephillips! Managed to find the issue you reported here (fixed in #371). Will release a new version soon 🙂 Thanks for the report


Directives mounted called after beforeUpdate

Vue version
3.5.13
Link to minimal reproduction
https://play.vuejs.org/#eNp9VE1vEzEQ/SuWL03VZFMUeglJBFQ5wAGqtogDRmizO9m48dorfyxBq/3vjL1foSS52TPP4zfznl3RD0URlQ7onC5MonlhiQHrCiJimS2tWTHJ80JpSx7iDMhWq5wwGk39zp9jtAdUxOxiIdTvR9iSuoO2GCYTJY0lha+yPEKOpBPimkm89ZnnoJwdja7JchWQURkL5/H+ujG5u71F5GLaEEVquLGQFyK2sCKESUIW9wrZSJCWzLlZMurLMEqmiF5MezCTdEytQU5bnkUvRkkcQOULMJpgBS5Afy0sR86MzknI+Fxg/TnErHYw7uLJDpL9ifiLOfgYow8aDOgSqfQ5G+sMbJNeP32BA677ZK5SJxB9IfkIRgnnOTawj06mSPsIF9h+CupwmT2b9cGCNF1TnqhH1gEflPLDO9f6QHcWvQ3nmKxxit91XBSgz5sIj2KlwUgV0f8Z5N3gEJQcBUfIiNGNyxhFyZtMopy0oNustwKTWycTz5Uo+eSvRO8ExlilN8+V2l8h17POCb5JeRkW/yxxw2XhkNQEZw4Ce8GiaCf7pwDcGIh1sgv2QksrJ1KyAeypqkIbde2tH8pMz9T/ZqDvyyrfGBplh6HWxShA1QPqOng8FNk4a7Ht94ngyR6ptJibGxw1l0m0mDaI7tIjAm3ECIWPpJ1beCAD7PVTud9xkZ6SGNONOJBzi7NOYcslrHFjRj/8gBDD6E/UygNQ0jZy/h2/UiPcfIla9xOdYNYarnXo8HkdWfbo/wo3DaC+ZQ+5xLUrX078RFGK2FrdOD7MualbTjZcpkO2H3h7/ERnv0rQ/rViZ7PoLnozo/VfG1jmXA==
Steps to reproduce
Just open the repro.
What is expected?
The result should show [ ok ] should be "ok".
What is actually happening?
The result shows [ bug ] should be "ok".
Clicking on button "inc" will force a new render of the component, which will fix the page.
System Info
System:
    OS: Windows 10 10.0.19045
    CPU: (12) x64 Intel(R) Core(TM) i7-9850H CPU @ 2.60GHz
    Memory: 3.66 GB / 15.79 GB
  Binaries:
    Node: 21.7.0 - C:\Program Files\nodejs\node.EXE
    npm: 10.5.0 - C:\Program Files\nodejs\npm.CMD
  Browsers:
    Edge: Chromium (127.0.2651.98), ChromiumDev (129.0.2752.4)
  npmPackages:
    vue: ^3.5.13 => 3.5.13

Any additional comments?
This reproduction is extremely fragile and I had a hard time creating it.
The core of the issue is incorrect queued hooks execution order, and most changes you would do to the repro are going to fix it.
If you want to see the page working correctly from the get go, just remove the timeout in App.vue and directly set page.value = Page.
Here's what I found out when debugging this myself:
The input is driven by a v-model, so the value is not really "rendered" by script setup, but it's instead set on elements by vModelText core directive. This will explain why the interpolation {{ val }} is rendered with the correct value, whereas the <input> shows the initial value instead.
The reproduction is setup in such a way that vModelText hooks are called in incorrect order.
After event onSetup is processed by Wrapper, the component is rendered again, and vModelText.beforeUpdate is called with the new value. If you break at this point you'll see the repro displaying the correct values.
But then, it looks like the directive mounted hook has not been executed yet. It is enqueued by Vue core mountElement function here:
https://github.com/vuejs/core/blob/fc4bbf95c1f9c8d9591e82571008578da15d7677/packages/runtime-core/src/renderer.ts#L715-L725
The issue seems to be that this call has captured the initial directive value and so restores the previous, incorrect value into the input element.

Additionally, the onMounted of the Wrapper.vue is also called after onBeforeUpdate. see Playground, Observe the console logs.

A simpler minimal reproduction
We can see that the breakpoints in setTimeout, beforeUpdate, and mounted are triggered in sequence


Build a Docker Image into ghcr or dockerhub

The docker compose is great for test it, as well the live Demo and for those of us who already have running an ollama or something similar an oficial image to pull would be great to be updated. Thanks!

This is now live!  See this new section in the README


[Maintenance] Add support for max number of items in cache and eviction strategies

https://github.com/bluele/gcache seems to support all requirements with proper callbacks to move data to disk on eviction

Closing - Outdated requirement


[DO NOT MERGE] test if message lock lost error change works w/o updating tests

Checking that MessageLockLostError update in SBReceiver doesn't cause existing tests to fail, since SBError is parent. Sanity check as per https://github.com/Azure/azure-sdk-for-python/pull/30896#discussion_r1247308891

/azp run python - servicebus - tests

API change check
API changes are not detected in this pull request.


Doesn't seem to work with vetur for Vue

I don't know if you've used it with vue, but it doesn't seem to work. Or is there a workaround?

Expanding on this issue, I've had a lot of issues with prettier + vscode so far. The best solution was for me to set add "vue" as a language id in the main prettier plugin. This solved most of my troubles, however this solution doesn't work for prettier-now! Considering prettier-now has a huge upside in putting spaces before parenthesis, this was a big disappointment. It would be awesome if this bug could be fixed.

why is this issue closed @chanlito @remimarsal  ?

@Shuunen I close this because I don't know if @remimarsal would want to support this or not?

I understand, he will choose whether its an issue or not


list() method of users, clients - Error: Invalid value not allowed

Hello Team, I'm trying to use this SDK in my FastAPI project and I'm encountering some errors with the list method.
dependencies info:
python = "^3.10"
fastapi = "^0.112.1"
uvicorn = "^0.30.6"
beanie = "^1.26.0"
python-multipart = "^0.0.9"
clerk-backend-api = "^0.5.0a11"

When I tried:
class ClerkService:
    def __init__(self):
        self.client = Clerk(bearer_auth=token)

    def get_email_info(self, email):
        return self.client.email_addresses.get(email_address_id=email)

if __name__ == "__main__":
    clerk_service = ClerkService()

    print(clerk_service.client.users.list(limit=5))

It showed an error like:
clerk_backend_api.models.clerkerrors.ClerkErrors: {"errors":[{"code":"form_param_value_invalid","long_message":"5.0 does not match one of the allowed values for parameter limit","message":"is invalid","meta":{}}]}

I tried to modify getuserlistop.py
Before
    limit: Annotated[Optional[float], FieldMetadata(query=QueryParamMetadata(style="form", explode=True))] = 10
	...
    offset: Annotated[Optional[float], FieldMetadata(query=QueryParamMetadata(style="form", explode=True))] = 0
	...

To
    limit: Annotated[Optional[int], FieldMetadata(query=QueryParamMetadata(style="form", explode=True))] = 10
	...
    offset: Annotated[Optional[int], FieldMetadata(query=QueryParamMetadata(style="form", explode=True))] = 0
	...

After change, It worked.
I got the same error in all other list methods. Can I create a PR to change the float type to int?

Facing the same issue here

Hi @JettChenT and @hglong16 . This should be fixed in https://github.com/clerk/clerk-sdk-python/releases/tag/v0.5.0-alpha.12


add security audit metadata for vitess

[image: Screenshot 2023-07-18 at 11.00.26 AM.png]
They should display somewhere in the card :)
On Tue, Jul 18, 2023 at 10:51 AM Jorge O. Castro @.***>
wrote:

These are just adding the audit metadata to each entry (I have about 15
more to do). We just need to figure out how to display it in the cards
themselves.
—
Reply to this email directly, view it on GitHub
https://github.com/cncf/landscape/pull/3348#issuecomment-1640494232, or
unsubscribe
https://github.com/notifications/unsubscribe-auth/AAAPSIIXQCDWZE22JYM4IZ3XQ2WHBANCNFSM6AAAAAA2OQQ2SA
.
You are receiving this because you are subscribed to this thread.Message
ID: @.***>

--
Cheers,
Chris Aniszczyk
https://aniszczyk.org


replicate_multi_model changes to reduce number of cold boots

Description
Although the code in the "Generate Image Reasoning..." section works it takes a long time and incurs a huge cold boot penalty each time it switches models.  To avoid this I recommend a simple resequencing in the "for" loops to group operations for the same model together.  The change improves performance significantly - and was a much more respectful use of Replicate resources.
Existing order
for prompt_idx, prompt in enumerate(prompts):
    for image_idx, image_doc in enumerate(image_documents):
        for llm_idx, llm_model in enumerate(REPLICATE_MULTI_MODAL_LLM_MODELS):

Current change - recommended order for SIGNIFICANT performance boost
for llm_idx, llm_model in enumerate(REPLICATE_MULTI_MODAL_LLM_MODELS):
    for image_idx, image_doc in enumerate(image_documents):
        for prompt_idx, prompt in enumerate(prompts):

Documentation Link
https://github.com/run-llama/llama_index/blob/main/docs/examples/multi_modal/replicate_multi_modal.ipynb
Fixes # 11666
Type of Change
Please delete options that are not relevant.

[x] Bug fix (non-breaking change which fixes an issue)
[ ] New feature (non-breaking change which adds functionality)
[ ] Breaking change (fix or feature that would cause existing functionality to not work as expected)
[ ] This change requires a documentation update

How Has This Been Tested?
Please describe the tests that you ran to verify your changes. Provide instructions so we can reproduce. Please also list any relevant details for your test configuration

[ x ] Added new unit/integration tests
[ x ] Added new notebook (that tests end-to-end)
[ x ] I stared at the code and made sure it makes sense

Suggested Checklist:

[ x] I have performed a self-review of my own code
[ x] I have commented my code, particularly in hard-to-understand areas
[ ] I have made corresponding changes to the documentation
[ x] I have added Google Colab support for the newly added notebooks.
[ x] My changes generate no new warnings
[ ] I have added tests that prove my fix is effective or that my feature works
[ x] New and existing unit tests pass locally with my changes
[ ] I ran make format; make lint to appease the lint gods

removed

View entire conversation on ReviewNB

@donbr just a small ping, if possible, keeping the actual LLM outputs in the notebook is very helpful for users

Going to close this one out for now, its quite outdated at this point
If its still an issue, please raise an updated PR
Sorry for letting this one sit for so long!


Remove unused fields

Fixes / New Feature #
Proposed Changes
Remove unused fields that are causing compiler warnings.
Similar to https://github.com/ThreeMammals/Ocelot/pull/1208
but a different warning, this time with e.g.
Warning	CS0169
The field 'ReasonPhraseTests._contentLength' is never used
Ocelot.AcceptanceTests	C:\code\Ocelot\test\Ocelot.AcceptanceTests\ReasonPhraseTests.cs	15

Thanks for the PR!
After merging of develop to your feature branch the changes disappeared.
Strange!
It seems the same changes are already presented in develop branch.
Right?
And two files of tests in diff have zero changes too...
What to do with your PR?
It seems it is not relevant anymore.


installation failed

Env: python 3.9.1
I run chatgpt install, but with the following error:
result.txt

Closing due to inactivity.


@relation fields substracted from composite primary key @@id

Bug description
I have defined a composite primary key via @@id and one of the fileds is used in a @relation's fields list, in the same model. (see schema below)
While the migration creates all database fields correctly, one of the referenced @relation fields is substracted from the Typescript interface and therefore prevents insertion via .create().
It is clear that @relation itself is virtual, but I do not expect that parts from the composite primary key are substracted from the typescript model interface, which are regular database fields.
How to reproduce

Use the schema definition file (below).
Run: npx prisma migrate dev --name init
Look at the file node_modules/.prisma/client/index.d.ts

Expected behavior
The generated code is:
export type RecordingCreateInput = {
  filename: string
  channel: ChannelCreateNestedOneWithoutRecordingsInput
}

I was expecting:
export type RecordingCreateInput = {
  channelName: string
  filename: string
  channel: ChannelCreateNestedOneWithoutRecordingsInput
}

I don't know what *UncheckedCreateInput is, but that signature is correct:
export type RecordingUncheckedCreateInput = {
  channelName: string
  filename: string
}

Prisma information
model Channel {
  channelName String      @id @unique
  recordings  Recording[]
}

model Recording {
  channel      Channel   @relation(fields: [channelName], references: [channelName], onDelete: Cascade)
  channelName  String
  filename     String
  @@id([channelName, filename])
}

Environment & setup

OS: Ubuntu Server 20.04 / Linux thor 5.4.0-80-generic 90-Ubuntu SMP Fri Jul 9 22:49:44 UTC 2021 x86_64 x86_64 x86_64 GNU/Linux
Database: SQLite3 / 3.31.1 2020-01-27 19:55:54 3bfa9cc97da10598521b342961df8f5f68c7388fa117345eeb516eaa837balt1
Node.js version: v14.17.2

Prisma Version
Environment variables loaded from .env
prisma               : 2.28.0
@prisma/client       : 2.28.0
Current platform     : debian-openssl-1.1.x
Query Engine         : query-engine 89facabd0366f63911d089156a7a70125bfbcd27 (at<EMAIL_ADDRESS>Migration Engine     : migration-engine-cli 89facabd0366f63911d089156a7a70125bfbcd27 (at<EMAIL_ADDRESS>Introspection Engine : introspection-core 89facabd0366f63911d089156a7a70125bfbcd27 (at<EMAIL_ADDRESS>Format Binary        : prisma-fmt 89facabd0366f63911d089156a7a70125bfbcd27 (at<EMAIL_ADDRESS>Default Engines Hash : 89facabd0366f63911d089156a7a70125bfbcd27
Studio               : 0.417.0
Preview Features     : selectRelationCount, referentialActions

What problem is this causing? What Prisma Query can you not execute because of this, by your expectation, wrong type definition?

Ping @srad

I am going to close this as its been 3 months now and there is no activity here.
Please reply if you want us to take another look.


Sphinx Design tabs need other hover indicator other than just color change

Perhaps underline?
The PyData Theme docs has an example of Sphinx Design tabs, where this issue can be checked.

I need design to come up with the desired interaction and then I can implement.

Here's my design proposal:
We can add a simple underline like Gabriel suggested, and it would function akin to what we have in buttons right now.

Here's a demo loom:

Figma - Tabbed Interfaces (Hover) - PyData Design system - Watch Video

Decided that an underline is good for the hover state.

See https://github.com/pydata/pydata-sphinx-theme#1884


Double Click and Copy?

When using the GridData is there a way to have expose a double click instead of having to select a item/row then click ok or another button?
As for the copy I am using the "New-AnyBoxButton -Template 'CopyMessage'" command with gridData and I select an entry/row and select copy and a prompt display that "There is no message to copy."  Am I trying to use the template in a manner that it was not intended for?
--  I am wanting to copy the selection to clipboard.  If more then one property is selected include the property title in the copy.  I understand this may be difficult to perform.
Thanks for the updates

The CopyMessage template is meant to copy a message displayed to the user with the -Message parameter; it does not read the grid data. To copy grid data to the clipboard, I'd suggest using the keyboard shortcut CTRL+C. You could take a look at how the CopyMessage template works and use that as a guide to implement your own button with an -OnClick script that copies the selected grid data. PRs are welcome.


Add kustomization yaml

It would be great if a kustomization.yaml was available for easy deployment with kustomize.

Thanks for this pull request. I'm not familiar with kustomize. I'm going to read up on that before reviewing.

Please add the kustomization.yaml to this project since it would greatly simplify the installation of this project using Kustomize.
At my customer, all K8S service are always deployed via Kustomize since our infra always needs some addition custom configuration like NetworkPolicies, etc. With Kustomize, we can refer to the project's own deployment config (Helm Chart, Kustomize yaml or separate yaml's) and customise those for our environment.
Since origin-ca-issuer uses multiple yaml config's we now have to reference those ourselves and this would break of the project changes these filenames or adds or removes files.
By providing a kustomation.yaml we could just reference that file and automatically get any changes to the yaml configs.

Hi, is this PR going to be merged anytime soon ? I am trying to use kustomize to clone the deploy folder which will make it much easier if we have this feature added.

Hello. I'll be revisiting this soon.

Hello. We need this too. Thanks!

Would also love to see this merged!

You can test this already by using kustomize built into kubectl:
kubectl kustomize deploy/

I'd however also add a kustomization at the root of the repo so users can install it by doing
kubectl kustomize https://github.com/cloudflare/origin-ca-issuer
To see how this is done you can view: https://github.com/ricoberger/vault-secrets-operator or https://github.com/prometheus-operator/prometheus-operator/blob/main/kustomization.yaml


Fix: Remove deprecated linters

Description
Few linters were marked deprecated due to lack of active development upstream, removed them from the .golangci.yml configuration file
Type of Change

[ ] 📚 Documentation    (Non-breaking change; Changes in the documentation)
[ ] 🔧 Bug fix          (Non-breaking change; Fixes an existing bug)
[x] 🥂 Improvement      (Non-breaking change; Improves existing feature)
[ ] 🚀 New feature      (Non-breaking change; Adds functionality)
[ ] 🔐 Security fix     (Non-breaking change; Patches a security issue)
[ ] 💥 Breaking change  (Breaks existing functionality)

Review Process
Reviewees:

Prefer incremental and appropriately-scoped changes.
Leave a comment on things you want explicit feedback on.
Respond clearly to comments and questions.

Reviewers:

Test functionality using the criteria above.
Offer tips for efficiency, feedback on best practices, and possible alternative approaches.
For shorter, "quick" PRs, use your best judgment on the previous point.
Use a collaborative approach and provide resources and/or context where appropriate.
Provide screenshots/grabs where appropriate to show findings during review.
In case of a potential bug in PR, be sure to add steps to reproduce the issue (where applicable)

Closes #48


Keep 'client' running

instead of restarting each command, keep it running in 'creation' or 'presentation' mode.
add keys to:
a) add slide
n) next slide
p) previous slide
q) quit

benefits of running as client is to keep the commit list in memory, so that it can be checked in into version control as well from a main branch, and a presentation can be started from there.

Fixed in alpha.7


Enable API change detection as part of PR pipelines

Enable API change detection as part PR checks

API changes have been detected in this PR. You can review API changes here
API changes
+ def azure.template.template_code.template_main_test()
+
+


Fix compilation on recent betas of visionOS

In recent visionOS betas, #if os(xrOS) is now #if os(visionOS), and #if os(iOS) no longer returns true on visionOS. This required some updates to DeviceKit.
This is not meant to be a PR to fully support Apple Vision Pro information, just something to get DeviceKit building properly on the latest visionOS betas, and provide some scaffolding to start filling out information as it becomes available.
Fixes https://github.com/devicekit/DeviceKit/issues/370

Hi, any news on this?

@chrisvasselli @BProg
I've made another PR, that doesn't exclude the entire library when compiling. I'm unable to reproduce the actual issue you are having so could you try my PR or provide an example project where it is happening?
https://github.com/devicekit/DeviceKit/pull/376

Hi @Zandor300!
You can reproduce the issue by opening the DeviceKit workspace from this repo, and adding Vision Pro to the supported destinations. Then select the Vision Pro simulator as your run destination and attempt to build.
If you're still having trouble reproducing, please let me know!


Kafka Consumer lag and batching

Description
We have a dotnet kafka consumer running in a continuous web job in Azure.  We can't get the consumer to keep up with the amount of messages produced.  However, if we create a java client and wire it up we can get the lag to go down and we get caught up to real time.    If we switch back on the dot net consumer the message lag starts to increase again.
In java we can configure the consumer to give us a batch of messages and that seems to be the key.  Currently we haven't configured fetch max bytes in the dotnet client so it's whatever the default is(52mb i think).   Is this possible in the Confluent consumer?
We are running Confluent.Kafka 1.5.0.  in a .Net 3.1 worker service in azure app service.
How to reproduce
The vendor kafka is setup so we only get one partition.  But this doesn't seem to be an issue for a java client.
Checklist
Please provide the following information:

[ ] A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
[ ] Confluent.Kafka nuget version.
[ ] Apache Kafka version.
[ ] Client configuration.
[ ] Operating system.
[ ] Provide logs (with "debug" : "..." as necessary in configuration).
[ ] Provide broker log excerpts.
[ ] Critical issue.

the .NET consumer performance is comparable to the java client. but unlike the java client, it delivers messages to your application one at a time from an internal cache. are you calling commit frequently? that would slow things down. if so, consider StoreOffsets.

the .NET consumer performance is comparable to the java client. but unlike the java client, it delivers messages to your application one at a time from an internal cache. are you calling commit frequently? that would slow things down. if so, consider StoreOffsets.

It's set to autocommit and the default of 5000 ms.

feel free to paste some code

//thanks for taking look.  it's basic consume example.
public async Task Execute()
{
        try
        {
            using (_consumer)
            {
                _consumer.Subscribe(_streamConsumerSettings.Topic);
               while (!_cancelConsume)
               {
                    var result = _consumer.Consume(1000);

                    if (result?.IsPartitionEOF == true)
                    {
                        _logger.LogInformation("IsPartitionEOF = true");
                    }
                    if (result == null)
                    {
                        _logger.LogInformation("result from consume was null.  Continuing");
                        continue;

                    }
                    var topicPartitionOffset = result?.TopicPartitionOffset;
                    var equipmentEx = _deserializer.Deserialize(result.Message.Value);

                    var mappedEquipment = new Equipment();

                    try
                    {
                        mappedEquipment = _mapper.Map<Equipment>(equipmentEx);
                        mappedEquipment.TopicParitionOffset = topicPartitionOffset?.ToString();

                         await _eventHubClient.SendAsync(mappedEquipment);

                    }
                catch (OutOfMemoryException me)
                {
                    _logger.LogError(me, me.StackTrace ?? me.Message);

                }
                catch (Exception ex)
                {
                    _logger.LogInformation("Bad mapping");
                    _logger.LogError(ex, ex.StackTrace ?? ex.Message);

                }
              }
            }
        }
        catch (ConsumeException e)
        {
            _logger.LogError(e, e.StackTrace ?? e.Message);
            _cancelConsume = true;
            _consumer.Close();
            RestartConsumer();
        }
    }

//here's my config object.
private static ConsumerConfig GetConfig()
{
var config = new ConsumerConfig
{
BootstrapServers = _streamConsumerSettings.Bootstrapservers,
GroupId = _streamConsumerSettings.GroupId,
AutoOffsetReset = AutoOffsetReset.Latest,
AutoCommitIntervalMs = 20000,
SaslUsername = _streamConsumerSettings.Username,
SaslPassword = _streamConsumerSettings.Password,
SecurityProtocol = SecurityProtocol.SaslSsl,
SaslMechanism = SaslMechanism.Plain,
LogConnectionClose = true,
FetchMaxBytes = 100000000,
FetchMinBytes = 52000000,
EnableAutoCommit = true
};
return config;
}

I updated a few values as I was chatting.  so those are just local changes and I don't have the fetch min/max running on the real web job.  Same with the AutoCommitInterval.  That's default.

[2020-09-23 16:13:00,741] INFO [GroupCoordinator 1]: Assignment received from leader for group sunstate-testclient for generation 2120 (kafka.coordinator.group.GroupCoordinator)
[2020-09-23 16:22:50,424] INFO [GroupCoordinator 1]: Member rdkafka-f0e673f3-2cfd-4d4b-be68-b34fdc857ac7 in group sunstate-testclient has failed, removing it from the group

[2020-09-23 16:13:00,741] INFO [GroupCoordinator 1]: Assignment received from leader for group testclient for generation 2120 (kafka.coordinator.group.GroupCoordinator)
[2020-09-23 16:22:50,424] INFO [GroupCoordinator 1]: Member rdkafka-f0e673f3-2cfd-4d4b-be68-b34fdc857ac7 in group testclient has failed, removing it from the group

probably best not to mix async and sync code (the consume method is sync). just using .Result should be ok, but this shouldn't be causing an issue. looks ok. enable debugging set Debug config property to all for more information about why the consumer is being kicked out of the group.

%7|1600890755.843|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received JoinGroupResponse (v5, 209 bytes, CorrId 89, rtt 3381.78ms)
%7|1600890755.843|JOINGROUP|rdkafka#consumer-1| [thrd:main]: JoinGroup response: GenerationId 2160, Protocol range, LeaderId rdkafka-c6e0aac7-646f-4b26-9296-96725de53de8 (me), my MemberId rdkafka-c6e0aac7-646f-4b26-9296-96725de53de8, 1 members in group: (no error)
%7|1600890755.845|JOINGROUP|rdkafka#consumer-1| [thrd:main]: Elected leader for group "testclient" with 1 member(s)
%7|1600890755.846|GRPLEADER|rdkafka#consumer-1| [thrd:main]: Group "testclient": resetting group leader info: JoinGroup response clean-up
%7|1600890755.846|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testclient" changed join state wait-join -> wait-metadata (v21, state up)
%7|1600890755.846|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Request metadata for 1 topic(s): partition assignor
%7|1600890755.847|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent MetadataRequest (v4, 60 bytes @ 0, CorrId 90)
info: StreamConsumer[0]
result from consume was null.  Continuing
%7|1600890756.016|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received MetadataResponse (v4, 282 bytes, CorrId 90, rtt 168.65ms)
%7|1600890756.017|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: ===== Received metadata (for 1 requested topics): partition assignor =====
%7|1600890756.018|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: ClusterId: nefLlgJkQ06m_yUnsyj8yQ, ControllerId: 2
%7|1600890756.018|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: 3 brokers, 1 topics
%7|1600890756.018|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Broker #0/3: streamin-url:31090 NodeId 0
%7|1600890756.018|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Broker #1/3: streamin-url:31092 NodeId 2
%7|1600890756.019|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Broker #2/3: streamin-url:31091 NodeId 1
%7|1600890756.020|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1:   Topic #0/1: topic-name with 1 partitions
%7|1600890756.021|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic topic-name partition 0 Leader 1
%7|1600890756.022|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: 1/1 requested topic(s) seen in metadata
%7|1600890756.022|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testclient" running range assignment for 1 member(s):
%7|1600890756.023|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-c6e0aac7-646f-4b26-9296-96725de53de8" (me) with 1 subscription(s):
%7|1600890756.024|ASSIGN|rdkafka#consumer-1| [thrd:main]:   topic-name [-1]
%7|1600890756.025|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Topic topic-name with 1 partition(s) and 1 subscribing member(s)
%7|1600890756.026|ASSIGN|rdkafka#consumer-1| [thrd:main]: range: Member "rdkafka-c6e0aac7-646f-4b26-9296-96725de53de8": assigned topic topic-name partitions 0..0
%7|1600890756.027|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testclient" range assignment for 1 member(s) finished in 4.254ms:
%7|1600890756.041|ASSIGN|rdkafka#consumer-1| [thrd:main]:  Member "rdkafka-c6e0aac7-646f-4b26-9296-96725de53de8" (me) assigned 1 partition(s):
%7|1600890756.042|ASSIGN|rdkafka#consumer-1| [thrd:main]:   topic-name [0]
%7|1600890756.043|ASSIGNOR|rdkafka#consumer-1| [thrd:main]: Group "testclient": "range" assignor run for 1 member(s)
%7|1600890756.044|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testclient" changed join state wait-metadata -> wait-sync (v21, state up)
%7|1600890756.045|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent SyncGroupRequest (v3, 200 bytes @ 0, CorrId 91)
%7|1600890756.045|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1600890756.428|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received SyncGroupResponse (v3, 62 bytes, CorrId 91, rtt 383.07ms)
%7|1600890756.429|SYNCGROUP|rdkafka#consumer-1| [thrd:main]: SyncGroup response: Success (52 bytes of MemberState data)
%7|1600890756.441|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testclient": new assignment of 1 partition(s) in join state wait-sync
%7|1600890756.442|DESIRED|rdkafka#consumer-1| [thrd:main]: topic-name [0]: marking as DESIRED
%7|1600890756.443|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "testclient": rd_kafka_cgrp_assign:2600: new version barrier v22
%7|1600890756.444|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "testclient": assigning 1 partition(s) in join state wait-sync
%7|1600890756.445|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testclient" changed join state wait-sync -> assigned (v22, state up)
%7|1600890756.446|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "testclient": rd_kafka_cgrp_partitions_fetch_start0:1878: new version barrier v23
%7|1600890756.447|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "testclient": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=no, v23, line 2651)
%7|1600890756.447|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1600890756.471|FETCHSTART|rdkafka#consumer-1| [thrd:main]:  topic-name [0] offset INVALID
%7|1600890756.479|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: OffsetFetchRequest(v1) for 1/1 partition(s)
%7|1600890756.480|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Fetch committed offsets for 1/1 partition(s)
%7|1600890756.482|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent OffsetFetchRequest (v1, 88 bytes @ 0, CorrId 92)
%7|1600890756.482|HEARTBEAT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: Heartbeat for group "testclient" generation id 2160
%7|1600890756.507|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Sent HeartbeatRequest (v3, 94 bytes @ 0, CorrId 93)
%7|1600890756.653|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received OffsetFetchResponse (v1, 58 bytes, CorrId 92, rtt 170.27ms)
%7|1600890756.653|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1600890756.663|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]:  topic-name [0] offset INVALID
%7|1600890756.664|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic topic-name [0]: setting default offset INVALID
%7|1600890756.665|OFFSETFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: OffsetFetchResponse: topic-name [0] offset 186450163, metadata 0 byte(s)
%7|1600890756.665|OFFFETCH|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/1: OffsetFetch for 1/1 partition(s) returned Success
%7|1600890756.666|BARRIER|rdkafka#consumer-1| [thrd:main]: Group "testclient": rd_kafka_cgrp_partitions_fetch_start0:1878: new version barrier v24
%7|1600890756.667|FETCHSTART|rdkafka#consumer-1| [thrd:main]: Group "testclient": starting fetchers for 1 assigned partition(s) in join-state assigned (usable_offsets=yes, v24, line 1810)
%7|1600890756.668|FETCHSTART|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1600890756.669|FETCHSTART|rdkafka#consumer-1| [thrd:main]:  topic-name [0] offset 186450163
%7|1600890756.669|CGRPJOINSTATE|rdkafka#consumer-1| [thrd:main]: Group "testclient" changed join state assigned -> started (v24, state up)
%7|1600890756.689|BARRIER|rdkafka#consumer-1| [thrd:main]: topic-name [0]: rd_kafka_toppar_op_fetch_start:2299: new version barrier v22
%7|1600890756.690|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming topic-name [0] at offset 186450163 (v22)
%7|1600890756.706|OP|rdkafka#consumer-1| [thrd:main]: topic-name [0] received op FETCH_START (v22) in fetch-state stopped (opv21)
%7|1600890756.753|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for topic-name [0] in state stopped at offset 186450163 (v22)
%7|1600890756.788|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition topic-name [0] changed fetch state stopped -> active
%7|1600890756.791|FETCH|rdkafka#consumer-1| [thrd:main]: Partition topic-name [0] start fetching at offset 186450163
%7|1600890756.807|WAKEUP|rdkafka#consumer-1| [thrd:main]: sasl_ssl://streamin-url:31091/1: Wake-up
%7|1600890756.823|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Received HeartbeatResponse (v3, 6 bytes, CorrId 93, rtt 315.34ms)
%7|1600890756.830|FETCHDEC|rdkafka#consumer-1| [thrd:sasl_ssl://streamin-url:31091/boot]: Topic topic-name [0]: fetch decide: updating to version 22 (was 18) at offset 186450163 (was 186512161)
%7|1600890756.830|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "testclient" received op PARTITION_JOIN in state up (join state started, v24) for topic-name [0]
%7|1600890756.912|FETCH|rdkafka#consumer-1| [thrd:sasl_ssl://streamin-url:31091/boot]: sasl_ssl://streamin-url:31091/1: Topic topic-name [0] in state active at offset 186450163 (0/100000 msgs, 0/65536 kb queued, opv 22) is fetchable
%7|1600890756.924|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "testclient": add topic-name [0]
%7|1600890756.948|FETCHADD|rdkafka#consumer-1| [thrd:sasl_ssl://streamin-url:31091/boot]: sasl_ssl://streamin-url:31091/1: Added topic-name [0] to fetch list (1 entries, opv 22, 0 messages queued): fetchable
%7|1600890756.964|FETCH|rdkafka#consumer-1| [thrd:sasl_ssl://streamin-url:31091/boot]: sasl_ssl://url-obfuscated

that looks fine. how many messages per second are you getting and how large are the messages?

here's the message size is a byte[139].  i'm trying to get conduktor setup so i can see some more information about the lag.

await _eventHubClient.SendAsync(mappedEquipment); is synchronous, so it'll be slow

that could be the problem too eventually.  this is the first issue.    var equipmentEx = _deserializer.Deserialize(result.Message.Value);  Hand rolled deserialization of the Avro file.  When i take this out I can see the conduktor lag go way down.  Thanks for the help!  I just need to get these other pieces out of this loop.

Same case with me also getting performance issue while using below consumer.
In our use case we want to show some charts, metrices and grid based on Kafka topics data.( All Topics are already loaded with Json data from different systems )
We are planning to use Kafka connect and will sync topics data to Cassandra database.
Based on some trigger like any new data in Kafka topic will re-load UI  and read same data from Cassandra (Via Dot Net core APIs) and display it on UI.
So is it good idea to use Kafka connect and sync data to Cassandra and query on Cassandra to load UI data Realtime.
Note : Reading data directly from Kafka topics and display on UI using Dot net Kafka consumer is very slow as in our use case we need to query 4-5 topics to get required data.
private List<Dictionary<string, object>> RetrieveDataWithGenericRecordKey(CachedSchemaRegistryClient schemaRegistryClient, string topicName, CancellationTokenSource cts)
{
var processedResult = new List<Dictionary<string, object>>();
        using (var consumer = new ConsumerBuilder<GenericRecord, GenericRecord>(consumerConfig)
            .SetKeyDeserializer(new CustomAvroDeserializer<GenericRecord>(schemaRegistryClient).CustomAsSyncOverAsync())
            .SetValueDeserializer(new CustomAvroDeserializer<GenericRecord>(schemaRegistryClient).CustomAsSyncOverAsync())
            .SetErrorHandler((_, e) => Console.WriteLine($"Error: {e.Reason}"))
            .Build())
        {

            Dictionary<string, object> results = new Dictionary<string, object>();

            consumer.Subscribe(topicName);

            try
            {
                while (true)
                {
                    try
                    {
                        // consumer.Subscribe(topicName);

                        ConsumeResult<GenericRecord, GenericRecord> consumeResult = consumer.Consume(cts.Token);

                        if (consumeResult.IsPartitionEOF)
                        {
                            return processedResult;
                        }

                        Dictionary<string, object> obj = new Dictionary<string, object>();
                        var result = ProcessRetrievedResult(consumeResult);
                        processedResult.Add(result);

                    }
                    catch (ConsumeException e)
                    {
                        Console.WriteLine($"Error occurred: {e}");

                    }
                }
            }
            catch (OperationCanceledException)
            {
                // Ensure the consumer leaves the group cleanly and final offsets are committed.
                consumer.Close();
            }
        }

        return processedResult;
    }


sp; mf ... leaves cursor visible in the inactive pane

When I, for example, wt sp cmd.exe; mf 1, the cursor remains visible in the inactive pane.  This is unlike moving focus in other situations; normally the cursor is hidden in an inactive pane.

Version number?

That was the 20 release and the 21 preview.  I just updated and the same is true of WindowsTerminal 1.22.2408.23002 (preview) and WindowsTerminal 1.21.2408.23001.
And I'm seeing this for the first time when starting the 1.21 release.

That's apparently from
        {
            "id": null,
            "keys": "ctrl+shift+w"
        },

Any idea?

When I, for example, wt sp cmd.exe; mf 1, the cursor remains visible in the inactive pane. This is unlike moving focus in other situations; normally the cursor is hidden in an inactive pane.

Any more on this?

If you have looked into this you've probably figured out that it's a matter of timing.  I can reproduce the undesirable behavior (cursor showing in the inactive pane) with simulated keystrokes (using TCC's KEYSTACK command).
keystack alt-shift-+ alt-left
If I introduce a delay (9/18 second below) before moving focus, the cursor is not showing in the inactive pane.
keystack alt-shift-+ /w9 alt-left

And I'm seeing this for the first time when starting the 1.21 release.

Is the null from you or automatically generated by us? I'm assuming the latter. In that case I think it's a bug in #17162 and I suppose we fail to remove bindings that have no action?

I believe this issue also happens even if all you do is unfocus the application, while the terminal is currently busy with processing output that doesn't move the cursor (= pure VT).
DispatchTimer::Stop neither cancels the pending nor blocks until the queued event is done:

If Stop is called when the timer interval has just elapsed, it's possible that the timer already queued a Tick event. This event will still be raised.

So, when we do "stop the timer, then disable the cursor", we may still get a blink tick.

I don't think I put that null in there.

I found other ways to leave the cursor showing in an inactive pane also.  One is to just do the keystrokes quickly enough ... Alt-Shift-+, Alt-Left.


CustomPins.Add and Clear

After upgrading the version of the package (to last), the methods add and clear the CustomPins Collection were removed, what happened?
TKCustomMap map;
var CustomPin = new TKCustomMapPin ();
CustomPin.ShowCallout = true;
CustomPin.DefaultPinColor = Color.Red;
CustomPin.Position = new Xamarin.Forms.Maps.Position (item.Y,item.X);
CustomPin.Title = item.Value.ToString ();
CustomPin.Subtitle = item.Endereco;
map.CustomPins.Add(CustomPin);

Hi,
CustomPins was changed from ObservableCollection to IEnumerable. That lets you not just bind ObservableCollection but everyhting which implements IEnumerable. On IEnumerable there are no Add, Remove or Clear functions available.
Change your code like this to make it exactly work like before:
ObservableCollection<TKCustomMapPin> myList = new ObservableCollection<TKCustomMapPin>();
map.CustomPins = myList;

var CustomPin = new TKCustomMapPin ();
CustomPin.ShowCallout = true;
CustomPin.DefaultPinColor = Color.Red;
CustomPin.Position = new Xamarin.Forms.Maps.Position (item.Y,item.X);
CustomPin.Title = item.Value.ToString ();
CustomPin.Subtitle = item.Endereco;

myList.Add(CustomPin);

Thank you for your attention and for your great work

You are very much welcome


BigQuery connection does not working on 1.7.0

Dear Airflow Maintainers,
Before I tell you about my issue, let me describe my environment:
Environment

Version of Airflow: 1.7.0
Python Version: 2.7.10
(Optional) Python packages:
airflow==1.7.0
pandas==0.18.0

Now that you know a little about me, let me tell you about the issue I am having:
Description of Issue

What did you expect to happen?
see query results
What happened instead?
The following error message appears:

'BigQueryPandasConnector' object has no attribute 'test_google_api_imports'

Here is how you can reproduce this issue on your machine:

Reproduction Steps

Setup a BigQuery Connection on Admin > Connections page
On Data Profiling > Ad Hoc Query page, try to run some query using the connection set on the step before.

Can you:

Use 1.7.1rc1 (https://github.com/airbnb/airflow/tree/1.7.1rc1) instead of 1.7.0? 1.7.0 had a dependency issue for Google cloud that broke everything.
Verify that you've installed airflow[gcp_api]?

@WesleyBatista Actually, it looks like 1.7.1. is not good tag. cc/ @criccomini @jlowin @mistercrunch @bolkedebruin

@r39132 I think this might be the same thing that I'm seeing. When I grep for previously succeeded on, I find a ton of entries after upgrading to 1.7.1.

If 1.7.1 is bad, then I'd recommend dropping to 1.6.2, or waiting for the real 1.7.1 to be released (apparently the tag was pushed by accident).

Haven't heard anything from @WesleyBatista. Does rolling back to 1.6.2 help?

Sorry guys, I could not try anything since I published the issue.
I want to try to do a downgrade to 1.6.2, but I am a little bit concerned about the issues with some database modification done on any commit.

Sorry not being able to be fully commited with this issue and not replying in time, but I will try your guesses.

@WesleyBatista you should be able to downgrade the DB if you need to. From the dir where Airflow is installed, run:
alembic downgrade <checksum>

Where  is the checksum that you want to downgrade to. Checksums can be viewed in the migrations directory.

Cool then! ☺ thanks very much for the tip. I will try this tomorrow as
soon as I can.
Em 14 de abr de 2016 20:46, "Chris Riccomini"<EMAIL_ADDRESS>escreveu:

@WesleyBatista https://github.com/WesleyBatista you should be able to
downgrade the DB if you need to. From the dir where Airflow is installed,
run:
alembic downgrade
Where is the checksum that you want to downgrade to. Checksums can be
viewed in the migrations directory.
—
You are receiving this because you were mentioned.
Reply to this email directly or view it on GitHub
https://github.com/airbnb/airflow/issues/1354#issuecomment-210206053

Checking in.

@WesleyBatista going to close this if I don't hear back within 24h.

I have been able to reproduce this issue.

I will fix it as part of AIRFLOW-16 (https://issues.apache.org/jira/browse/AIRFLOW-16).

This is caused by backwards incompatible changes that Pandas made.

This is fixed as part of:
https://issues.apache.org/jira/browse/AIRFLOW-16


Unified schema

This includes some larger breaking changes to the packet definition schema.

loop was removed

Although this isn't very breaking since it was never used.

The struct schema was removed completely, everything uses the packet schema now
Each document can now define multiple packets and structures

Right now there are many documents that only contain a single tiny packet, these could be merged later, which would make things more readable. Also related packets and structs can be placed in the same file.

Uuid structure was removed, uuid intrinsic was added instead.

I've also added some documentation to the schema itself and the README. Besides just changing the format of every packet definition file, I also did some minor fixes. There is some extra validation in the schema, but nothing failed on those.

As we've briefly discussed, the nativeparam intrinsic does not encode parameters as described by paramlist.ini.
Packets referring to params as in paramlist.init would be CPktBlob and CPktAvatarUpdate (CPktStackedAvatarUpdate too I suppose). We could add an intrinsic for those - right now they are just described as byte arrays - but to fully parse them, a "class id" (referring to the unique id of a class in paramlist.ini) is required. In case of CPktBlob the "class id" is part of the packet, but CPktAvatarUpdate and possibly CPktStackedAvatarUpdate might omit it, preventing a potential intrinsic of beeing fully parseable without context.

Fixed the nativeparam description.
Yeah, it would be nice to do something with the paramlist stuff later, but for now it's probably more trouble than it's worth.


possible to stream over mutual TLS connection?

I'm working on streaming data from the docker daemon and encountering issues with streaming when paired with a TLS auth'd connection. Stream coercion using {:as :stream} is working as expected with a standard http daemon, however it stalls completely when accessing the https counter part (I'm using a working :key-store and :trust-store options).
Am I missing something here?

So, responding to this over a year late (😢), but when it stalls, can you enable logging for the apache http client part and see where it's hanging?

@dakrone https://github.com/ztellman/aleph turned out to be a better match specifically for the streaming stuff. It I open up this task again I will notify thanks!


Add support for .pyw files

Fixes issue with GUI titles having 'w' in the name when using a file ending in .pyw

Make sure to complete the PR checklist (it's that thing you deleted/ignored while creating the pull request ^_^). Feel free to re-open against the correct branch.


Route replay with events

I'm checking if I'm going in the right direction.
The idea is to show events on the route replay:
https://github.com/traccar/traccar-web/assets/31902485/950340fb-f99a-4cfd-be78-a5037b695f15

The idea is to use combined report to show events on a route.

ok, I'll check it out, thanks.


Fix version import

Address version import, see here.

Just a suggestion. We should separate lint fix and the real issue in two PRs for the tracking purpose.


sequencer: make a masterqueue class (or a queue class)

refactored queue stuff into a Score class.


Chore/serialization

The intend of this MR is to implement "binary" representations of all XRPL types in xrpl_types and serialization of XRPL objects using these types according to https://xrpl.org/serialization.html. The changes from the previous implementation of serialization are

The XRPL data types are now "strongly" typed with a representation that is based on its natural binary representation
Serialization logic is split up in the serialization format in the Serializer implementation (implemented in xrpl_binary_codec) and what to serialize in the Serialize implementation (implemented for transactions in xrpl_types)
Parser has been removed for now, since it used to old data types. It should be reimplemented at some point using same data types and structure as the serializer

The current Amount and Currency types used in xrpl_api have been moved to xrpl_api. And now there are "binary" variants of these two types in xrpl_types.
I've splitup the stuff related to hashing, serializing and signing into the modules xrpl_binary_codec::hash/sign/serialize

Thanks for this MR, I will review later today!

Sorry the MR is a bit to the bigger side :)

Yeah, I will need some more time for this.

This looks like a very high-quality contribution. Instead of nit-picking, I suggest we merge this as is, and I can follow-up with some cosmetic/minor changes. Sounds good @allanbrondumkr ?

This looks like a very high-quality contribution. Instead of nit-picking, I suggest we merge this as is, and I can follow-up with some cosmetic/minor changes. Sounds good @allanbrondumkr ?

Yes, if you are happy with the overall changes and direction the code changes, it think that is the most important.


[Q] Extract IFrame

is there a way with tsduck to extract I-Frame from a live ts for a specific pid?

What do you mean by "extract I-Frame" ?
Extract the part of the video bitstream which makes an I-Frame? It depends on the video codec and TSDuck does not know how to decode each video codec to extract a frame.
It looks more a job for ffmpeg.


Move the kernel status plugin to its own repo

The notebook-extension currently has a plugin to show the kernel status in the menu area:
https://github.com/jtpio/jupyterlab-classic/blob/d6b870ad5b55a8362f9d1b890297216a53db2ce5/packages/notebook-extension/src/index.ts#L155-L210

This plugin could actually move to its own repo and be managed separately, so it could for example be installed as a prebuilt extension in JupyterLab too.
Also it might make more sense to have it in the notebook toolbar instead, next to the existing kernel status indicator:

Closing as we can keep it in the repo for now. If anyone would like to work on that feel free!


onEvent argument should be a function

I install your plugin and use your example, but show me error:
Error: onEvent argument should be a function
    at MySQLEvents.addTrigger (C:\wamp64\www\upport54\services\call_popup\node_modules\@rodrigogs\mysql-events\lib\MySQLEvents.js:166:46)
    at program (C:\wamp64\www\upport54\services\call_popup\file.js:14:14)
    at <anonymous>
    at process._tickCallback (internal/process/next_tick.js:188:7)

Sorry. The example was not updated. The callback argument was changed to onEvent.

After starting the monitor, I will encounter this error in about 10 hours. It has appeared many times.


#30 & #31: Add scaleFactorMax and scaleFactorMin props. Add onZoom and onPan…

… callback props.
I did not run the builds as I didn't want to clutter this PR, but I can run them once the changes are approved.
Let me know what you think! It's working pretty well for our application now :)

Considering adding a onAuto callback to this PR that fires when using the auto tool...
Thoughts?

I guess that this feature can be easily produced with a callback on onChangeValue
onChangeValue(()=>{
  if(tool !== TOOL_AUTO) return

  //code
})

Ahhh that makes sense. I'll try that out.

Anything else we need to do to get this PR merged? Some tests maybe?

I don't see any change from my last comment. Have you pushed your code?

Confused, thought your last comment was just a suggestion on how to get that same result - which it worked. I ended up using the onChangeValue callback on our implementation.

Sorry, not my last comment, but the previous one. I added few comments on the code...
https://github.com/chrvadala/react-svg-pan-zoom/pull/34#pullrequestreview-31292110

All looks good to me! @chrvadala

I've just found why you didn't see my review... I wrote it one week ago, but Github needs an explicit confirm and so it was in pending state. Now I guess that you can see it.
If there are some doubts or difficulties send me a comment!
Thanks for your support and sorry for this mistake

I see the changes requested now, thanks! I will hop on those.

Hi @brentoneill,
I've just released and merged all the recent features that has been implemented in ReactSVGPanZoom.
Could you take care of this PR and adapt it to this recent changes?
I'd like to merge it in the next version.
Thanks a lot!

@brentoneill @chrvadala
Are you going to wrap up this PR? If you don't have the time, I'd be happy to take it over, as I'd really like to use this functionality. It really appears to be 98% complete...

Hi @4chen500,
I guess that @brentoneill closed this PR because he hasn't enough time to work on it. If you wanted to work on these features, I suggest to split #30 and #31 into two different PR.
#31  should be extractable from this PR without too much work. #30 requires a lot of features not yet programmed.

I'd be happy to finish #31, but I closed this because I was not going to be able to fit in #30 any time soon.
@4chen500 - please feel free to tie this up.

So, is there any callback for zoom (in/out), pan, and fit to the viewer?

I've answered here https://github.com/chrvadala/react-svg-pan-zoom/issues/60#issuecomment-345296229


Override codecs used when calling encode

On the encode command it would be useful to be able to override the vcodec, acodec or scodec on demand, instead of having to re-add files into the queue.

:tada: This issue has been resolved in version 0.7.0 :tada:
The release is available on:

GitHub release

Your GitReleaseManager bot :package::rocket:


Add Alibaba Cloud Deploy methods

If you want close, please tell me why

@linziqiaolzq - Thank you for your contribution. We only add supported platforms on our official documentation. However, please create a community post on our community portal for the same.


Cicd fix build

I needed to make some adjustments as it wasn't building correctly. Mainly I

Upgraded the docker images to be the latest android images that still use java 17 (looks like a downgrade because i pushed the intial upgrade to main, sorry about that)
added the bundle path as newer versions of the bundler do not allow themself to write with root to protected paths
Upgrade coil-kt to fix okhttp 4.11 version bug
adjust the channel name for the notify

Thanks for fixing the pipeline and the dependency upgrades; lgtm!


Add Japanese translation link to README

Hi, thank you for using your wonderful library.
I have prepared a Japanese translation and would be happy if you could check it.

Hi @kalupas226, thanks so much for taking the time!
@tockrock actually opened a work-in-progress PR for a Japanese translation here: https://github.com/pointfreeco/swift-composable-architecture/pull/1117
Perhaps you two could collaborate and see if there's anything you could share?
@tockrock What do you think?

@stephencelis
Thanks for giving me advice!
@tockrock
I'm sorry. I was unaware that the Japanese translation was already prepared by you and I worked on it :bow:

@kalupas226 @tockrock I'm going to merge this as is, since it's helpful to be made available to folks. Please do feel free to collaborate on it further, though! And thanks both of you for taking the time! :smile:


Missing 4.2.2 fxcore image at ghcr.io

Summary of Bug
Missing 4.2.2 image on GitHub at https://github.com/functionx/fx-core/pkgs/container/fx-core.
This version is available at Docker's Hub at https://hub.docker.com/r/functionx/fx-core/tags
Can this version be pushed to GitHub Packages as well for consistency?
Version
n/a
Steps to Reproduce
n/a

For Admin Use

[ ] Not duplicate issue
[ ] Appropriate labels applied
[ ] Appropriate contributors tagged
[ ] Contributor assigned/self-assigned
[ ] Is a spike necessary to map out how the issue should be approached?

@kenorb Hi, Thank you for your feedback. Sorry, v4.2.2 was not adopted in the end. Please use other correct versions. The historical upgrade version of fxcore can be found here
ref: https://github.com/FunctionX/fx-core/releases/tag/v4.2.2-rc1