Embed hyper and friends directly into rama

The design of hyper is similar enough that we ideally can just use it as is. And in a way that has been done so far. However akin to Tower and friends it also became clear that some of our goals and scope is sufficiently different that there will always be a kind of friction or trade off.
We developed most of rama 0.2 with hyper. In prototypes it became clear that a fork is needed for certain preservation goals. At that point even better is to just embed it directly into the codebase.
We can keep track in our FORK document what commit we are in sync with so that we can keep the codebases in sync.
This ticket is mostly about the embedding work and the use of it. We can already adapt code and drop code where we see it fit. But extensive modifications in the name of traffic preservation and control is best to be left for later tickets, to keep the scope of this ticket somewhat manageable.

From hyper-util we only use TokioIo and Auto Connection. So those can be directly copied in without copying the client.
We can move all this code under rama::http::core. While doing so we can already remove code we do not need, and make things simpler by knowing we can just hardcode a direct connection to tokio.

However as to not distract from the current priority of getting the high level API, flow and design correct. And while this might impact our code around the http client / server and also things like http upgrades, that is ok. For now let's hold this of until we are ready with the other ongoing tasks which are more important as they are all highly impactful about the design direction of rama and reaching our goals. Embedding hyper as rama::http::core is more a cherry on the cake detail.


Source Control Pane shows the same view on different windows / workspaces

Issue Type: Bug

Steps

Open multiple files from wsl (Ubuntu) on non-workspace, local vscode window.
Open project workspace from local on another local vscode window, without closing first window.
Go to Source Control Pane on 2nd window (if project workspace has git setup).

Actual result
The non-workspace window also shows the same Source Control view (same files and changes) from the workspace window, even though the non-workspace window does not have any Source Control setup.
Expected result
The Source Control Pane should only be active (show changes) for those workspaces that have some source control setup, and shouldn't be active when editing multiple files on a non-workspace window.
 Please use the git.autoRepositoryDetection setting to customise the repository discovery behaviour. You can set the setting to subFolders in order for VS Code not to open git repositories for the loose files that are being opened.


feat(ingest): mark database_alias and env as deprecated

Adds pydantic_field_deprecated helper
Adds a custom ConfigurationWarning type
Removes duplicate config options from a few places

Checklist

[ ] The PR conforms to DataHub's Contributing Guideline (particularly Commit Message Format)
[ ] Links to related issues (if applicable)
[ ] Tests for the changes have been added/updated (if applicable)
[ ] Docs related to the changes have been added/updated (if applicable). If a new feature has been added a Usage Guide has been added for the same.
[ ] For any breaking change/potential downtime/deprecation/big changes an entry has been made in Updating DataHub

We need to mark deprecated things in https://github.com/datahub-project/datahub/blob/master/docs/how/updating-datahub.md


Automatically select corresponding radio button when choosing time with mouse

Currently if one of the time options is selected, Pester will not let you select an input field from the other with the mouse without first selecting the other radio button. For example, if the "in" radio button is selected, you can't use the mouse to select the "at" time or date field with the mouse without first setting the "at" radio button. It would be easier to just be able to click into the "at" time field and have the "at" radio button be set automatically.
(This is analogous to the ability to select the "Display ..." checkbox just by clicking on the "Display" text itself.)

Agree this would make sense. These radio buttons use a legacy/"discouraged" UI interface (NSMatrix) which should be replaced; this change would be easier to do as part of this work. (However, I am not sure if or when I would have time for this; this is mostly for anyone else who is interested.)


Notification payload userInteraction always false

I am always received userInteraction false, if click notification always userInteraction false. I dont know this bug or not. Anyone can help me?

Same issue..... 😐

https://github.com/react-native-community/push-notification-ios/pull/122

Thanks @Dallas62 i will try it tomorrow

Hi!
The version on dev branch fix this issue, can you test it ?
Regards

This issue should be fixed now 😉

I had a different case to this on iOS:
userInteraction prop is false when application is on the foreground. We use in app notifications so not really a big problem.
However when notification is in the background and killed state no matter if there is user interaction or not the userInteraction prop is always true.
Using:
    "@react-native-community/push-notification-ios": "1.3.0",
    "react-native-push-notification": "^4.0.0",
    "react-native": "^0.63.2",

@Dallas62 still not working

You need to install the latest version of the iOS library

@Dallas62 My bad sorry, userInteraction inside data, different with android version. But this method i am already using.

@Dallas62 I have updated to the latest iOS library "@react-native-community/push-notification-ios": "^1.5.0" here's what happened.
Received (while App at Foreground)
{"data": {"deeplink": "myapp://profile"}, "messageId": "1600313175552426", "mutableContent": true, "notification": {"body": "Welcome to my app", "ios": {}, "sound": "default", "title": "MyTitle"}, "sentTime": "1600314145"}

After Tapping (while App at Foreground)
{"badge": undefined, "data": {"userInteraction": 1}, "finish": [Function finish], "foreground": true, "id": undefined, "message": "Welcome to my app", "soundName": undefined, "title": "MyTitle", "userInteraction": false}

My questions:

We are suppose refer to userInteraction returned in data? Since it's returning 1 to me.
Spotting that my deeplink is missing in data after tapping on it. Is this expected?

Hi @TommyLeong
Can you test with a version before this PR: #122
Actually this should not have impacted the userInfo value, or the name of the property changed on "click".
https://github.com/react-native-community/push-notification-ios/pull/122/files

@Dallas62  i'm not using hook, im getting my notification here.
PushNotification.configure({
  // (optional) Called when Token is generated (iOS and Android)
  onRegister: function (token) {
    console.log("TOKEN:", token);
  },

  // (required) Called when a remote is received or opened, or local notification is opened
  onNotification: function (notification) {
    console.log("NOTIFICATION:", notification);

    // IM GETTING MY NOTIFICATION HERE

    // (required) Called when a remote is received or opened, or local notification is opened
    notification.finish(PushNotificationIOS.FetchResult.NoData);
  },
...etc codes
....etc codes
......etc codes

Yes but can you test with an older version of react-native-community/push-notification-iosprior to #122 to see the result ?

@Dallas62 Here's the result with 1.4.1 on iOS, with physical device tested. I hope this is clear to you. The data is missing after tapping notification at foreground.
Foreground
Received notification (while App at Foreground)
{
  "data": {
    "deeplink": "myapp://profile"
  },
  "messageId": "1600323847995493",
  "mutableContent": true,
  "notification": {
    "body": "Welcome to my app",
    "ios": {

    },
    "sound": "default",
    "title": "MyTitle"
  },
  "sentTime": "1600326575"
}

After Tapping notification (while App at Foreground)
{
  "badge": undefined,
  "data": {

  },
  "finish": [
    Functionfinish
  ],
  "foreground": true,
  "id": undefined,
  "message": "Welcome to my app",
  "soundName": undefined,
  "title": "MyTitle",
  "userInteraction": false
}

Background
Received notification (while App at Background)
N/A - JS don't run at background
After Tapping notification (while App at Background)
{
  "badge": undefined,
  "data": {
    "aps": {
      "alert": [
        Object
      ],
      "mutable-content": "1",
      "sound": "default"
    },
    "deeplink": "myapp://profile",
    "gcm.message_id": "I_HAVE_MASKED_THE_VALUE_HERE",
    "gcm.n.e": "1",
    "gcm.notification.sound2": "default",
    "google.c.a.c_id": "I_HAVE_MASKED_THE_VALUE_HERE",
    "google.c.a.e": "1",
    "google.c.a.ts": "I_HAVE_MASKED_THE_VALUE_HERE",
    "google.c.a.udt": "0",
    "google.c.sender.id": "I_HAVE_MASKED_THE_VALUE_HERE"
  },
  "finish": [
    Functionfinish
  ],
  "foreground": false,
  "id": undefined,
  "message": "Welcome to my app",
  "soundName": undefined,
  "title": "MyTitle",
  "userInteraction": true
}

Thanks for the feed back, so it's not related to the PR of userInteraction. I will try to find time to investigate on this.

Back to my question earlier, we are suppose refer to userInteraction returned in data? Since it's returning 1 to me.

If you are using the iOS library, yes.
I saw you are using the zo0r/react-native-push-notification library, you will have to wait for: https://github.com/zo0r/react-native-push-notification/commit/bedc8f646aab67d594f291449fbfa24e07b64fe8
I'm a bit busy actually to  finish the release. I will try to release it this weekend.

Yup. Using both zo0r/react-native-push-notification and this library. Alright, appreciate bro! I'll create a separate issue for the data missing.

@TommyLeong in my case, everything is fine. Could you please give AppDelegate.m, maybe I can help you

@gibrandev When you say everything is fine, are you getting the same response like mine?
Getting the "userInteraction": 1 within data
{
  "badge": undefined,
  "data": {
    "userInteraction": 1
  },
  "finish": [
    Functionfinish
  ],
  "foreground": true,
  "id": undefined,
  "message": "Welcome to my app",
  "soundName": undefined,
  "title": "MyTitle",
  "userInteraction": false
}

Yes like this
https://github.com/react-native-community/push-notification-ios#how-to-determine-push-notification-user-click
i think this is not a problem, because already in the readme. and in my case all notification inside in data

Yup, then we are getting the same. I was just confirming with Dallas whether this is expected. Apparently this is the  case

If you are using the iOS library, yes.
I saw you are using the zo0r/react-native-push-notification library, you will have to wait for: zo0r/react-native-push-notification@bedc8f6
I'm a bit busy actually to finish the release. I will try to release it this weekend.

Maybe you can modification this, before #122 i am used this.
This same with #122 maybe you can change that outside of the data
If you want 😄
// Called when a notification is delivered to a foreground app.
-(void)userNotificationCenter:(UNUserNotificationCenter *)center
      willPresentNotification:(UNNotification *)notification
        withCompletionHandler:(void (^)(UNNotificationPresentationOptions options))completionHandler
{
  // Still call the JS onNotification handler so it can display the new message right away
  NSDictionary *userInfo = notification.request.content.userInfo;
  NSMutableDictionary *userInfoCopy = [userInfo mutableCopy];
  userInfoCopy[@"userInteraction"] = @false;
  [RNCPushNotificationIOS didReceiveRemoteNotification:userInfoCopy
                                fetchCompletionHandler:^void (UIBackgroundFetchResult result){}];

  completionHandler(UNAuthorizationOptionSound | UNAuthorizationOptionAlert | UNAuthorizationOptionBadge);
}
// Required for the notification event. You must call the completion handler after handling the remote notification.
- (void)application:(UIApplication *)application
  didReceiveRemoteNotification:(NSDictionary *)userInfo
  fetchCompletionHandler:(void (^)(UIBackgroundFetchResult))completionHandler
{
  NSMutableDictionary *userInfoCopy = [userInfo mutableCopy];
  userInfoCopy[@"userInteraction"] = @true;
  [RNCPushNotificationIOS didReceiveRemoteNotification:userInfoCopy fetchCompletionHandler:completionHandler];
}

Maybe you can modification this, before #122 i am used this.
This same with #122 maybe you can change that outside of the data
If you want 😄
// Called when a notification is delivered to a foreground app.
-(void)userNotificationCenter:(UNUserNotificationCenter *)center
      willPresentNotification:(UNNotification *)notification
        withCompletionHandler:(void (^)(UNNotificationPresentationOptions options))completionHandler
{
  // Still call the JS onNotification handler so it can display the new message right away
  NSDictionary *userInfo = notification.request.content.userInfo;
  NSMutableDictionary *userInfoCopy = [userInfo mutableCopy];
  userInfoCopy[@"userInteraction"] = @false;
  [RNCPushNotificationIOS didReceiveRemoteNotification:userInfoCopy
                                fetchCompletionHandler:^void (UIBackgroundFetchResult result){}];

  completionHandler(UNAuthorizationOptionSound | UNAuthorizationOptionAlert | UNAuthorizationOptionBadge);
}
// Required for the notification event. You must call the completion handler after handling the remote notification.
- (void)application:(UIApplication *)application
  didReceiveRemoteNotification:(NSDictionary *)userInfo
  fetchCompletionHandler:(void (^)(UIBackgroundFetchResult))completionHandler
{
  NSMutableDictionary *userInfoCopy = [userInfo mutableCopy];
  userInfoCopy[@"userInteraction"] = @true;
  [RNCPushNotificationIOS didReceiveRemoteNotification:userInfoCopy fetchCompletionHandler:completionHandler];
}

@Dallas62 maybe you can help us. 😄

closed #122

@TommyLeong Have you found a solution for the missing data!! I can capture the data in Android but in iOS it's overwritten for some reason.

@TommyLeong Have you found a solution for the missing data!! I can capture the data in Android but in iOS it's overwritten for some reason.


[PUI] Lazy loading of global modals

Slight improvement to initial loading time by lazy-loading some global modals

Not sure how this would work. Maybe there is an eslint plugin, or the netlify analytics could detect that.

I'm going to close this out for now - the gains are marginal and it is leading to a number of weird issues that are hard to debug. Not worth the effort currently.


Range increase is too cheap, should scale with size of area

using a multiple/fraction of the perimeter


Entity APIs specification

Updated API docs with the high level API specs
Documentation can be viewed at : https://centralbackendsk.docs.apiary.io/#

@matthew-white you can use this branch to begin frontend work

Updated the API doc to reflect implementation. Updated doc can be reviewed at https://centralbackendsk.docs.apiary.io/#reference/entities


Documentation for  ICorDebugHeapSegmentEnum::Next simply duplicates documentation for ICorDebugHeapEnum::Bext

It looks like the documentation for this page is incorrect and is simply a duplicate of this page:
https://docs.microsoft.com/en-us/dotnet/framework/unmanaged-api/debugging/icordebugheapenum-next-method

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

ID: 981b9449-a085-8015-5612-2f01ba3d7d4b
Version Independent ID: 738fc0ea-5425-56a4-fc0d-cf6dd97d038a
Content: ICorDebugHeapSegmentEnum::Next Method
Content Source: docs/framework/unmanaged-api/debugging/icordebugheapsegmentenum-next-method.md
Product: dotnet-framework
GitHub Login: @tommcdon
Microsoft Alias: tommcdon

Hey Del, I think I just fixed the types also described in #18930 (COR_SEGMENT, rather than COR_HEAPOBJECT). Although you seem to point out that there's some content issue?

It looks like this bug is just a duplicate of the other one. The fix that you have for #18930 is sufficient.


Fix: Unit/UI test build error

Issue
Running Unit/UI test failed due to a build error on test specs

Expected
Build successfully
Steps to reproduce

Run make.sh
Run Unit/UI test on Xcode
Receive errors from Xcode

@markgravity I am wondering if this is related to tuist folder naming bug and is fixed in #514 🤔

Fixed


fix issue #195 caused by paho 2.0.0

This fixes the issue in the simplest possible way - simply by adding the paho.CallbackAPIVersion.VERSION1 argument.
I don't know what the callback api is all about or if we can move to version2, but this gets it working again without any hassle.
I've also pinned the paho-mqtt package to >=2.0.0

thanks


Double current user checking in unauthenticated pages.

Should perform one request to check current user status.

We setup more than one activates which are based on current user checking and we have no way to control the executing order, so sometimes may perform two requests.
I don't think this is a issue.
Only one time, not calling two requests each time.


Fix validating Kong image tests

Is there an existing issue for this?

[X] I have searched the existing issues

Problem Statement
The tests to validate Kong images fails constantly:
https://github.com/Kong/kubernetes-ingress-controller/actions/runs/6706653705
After investigation, we found the two configuration problems:

The router_flavor is set to expressions for tests with dbless Kong, while the used KIC image is 2.12 and does not include the change to remove the ExpressionRoutes feature gate, so the initial configurations could never be successfully sent
The integration tests detected that the Kong image is enterprise edition, and enables enterprise features, but the features could not be enabled because license is not provided.

Proposed Solution

When KIC image is below 3.0, configure router flavor to traditional_compatible or set feature gate ExpressionRoutes to true
Skip integration tests requiring enterprise feature when license is not given

Additional information
No response
Acceptance Criteria

[ ] Validation of Kong has no failures caused by misconfigurations of tests

@randmonkey Can you elaborate on the enterprise license aspect of this issue?
https://github.com/Kong/kubernetes-ingress-controller/actions/runs/6706653705/job/18223679900#step:9:5 does have the license env set

Skip integration tests requiring enterprise feature when license is not given

I'd say that

We should fail the test when license is not provided but TEST_KONG_ENTERPRISE="true" is set
We should skip the test if TEST_KONG_ENTERPRISE is not set

Ok fix is for the integration tests only right? Since it uses the patched RunWhenKongEnterprise. The e2e failures are a separate thing.


cake-contrib user on NuGet

@ecampidoglio what are your thoughts on doing this?
This was discussed here:
http://cakebuild.net/blog/2016/08/cake-contribution-organization
We are currently going through a process of increasing the visibility of addins, and also trying to ensure their long term maintainability.
To that end, we are asking addin creators to add the cake-contrib user on NuGet as a co-owner (this can be done through the NuGet website by clicking on Manage Owners on the package page).
https://www.nuget.org/profiles/cake-contrib
Would you be interested in doing this for Cake.Curl? If you have any questions about this, please let me know. There was some initial concern that the Cake Team were trying to "take over" packages, and that couldn't be further from the truth, and if you have this concern, or others, I would like to address them.
Thanks!

@gep13 While I understand the premise of this initiative—and I do agree that it brings value to the community—I'd like to wait before moving Cake.Curl to the cake-contrib org just yet.

@ecampidoglio yip, no issues there. The main thing that we are looking for here is adding the additional owner to the nuget package. Moving to the cake-contrib organisation is definitely not a requirement.

Done.
https://twitter.com/ecampidoglio/status/841577677215657984


[Bug]: Failed to start ImageSource

OS
Mac
App Version
v0.5.0
Description
Hello,
When I installed Vrig for the first time, it worked great but then it just stopped working for some reason I cannot understand. The button "start camera" stopped working suddenly, making only the model glitch for a split second and nothing more.
The logs indicate Failed to start ImageSource, exiting....
I tried restarting my computer, reinstalling the program, nothing has worked.
Logs
[13:50:41] Warn] [Bootstrap]: Application version: v0.5.0
[13:50:41] [Warn] [Settings]: language 'en_US'
[13:50:41] [Warn] [Settings]: camera.name 'Iriun Camera'
[13:50:41] [Warn] [Settings]: camera.flipped 'False'
[13:50:41] [Warn] [Settings]: camera.resolution '1920x1080 (30Hz)'
[13:50:41] [Warn] [Settings]: camera.resolution.custom 'False'
[13:50:41] [Warn] [Settings]: tracking.box '0,0,5000,5000'
[13:50:41] [Warn] [Settings]: tracking.box.enable 'False'
[13:50:41] [Warn] [Settings]: bone.mask '17407'
[13:50:41] Warn] [Settings]: bone.use.legs 'False'
[13:50:41] [Warn] [Settings]: tracking.threshold.hand 'O'
[13:50:41] [Warn] [Settings]: tracking interpolation '0.1'
[13:50:41] [Warn] [Settings]: gui.model '/Users/Sarah/Desktop/Raahs.vrm'
[13:50:41] [Warn] [Settings]: gui.image "
[13:50:41] [Warn] [Settings]: gui.show.custombackground 'False'
[13:50:41] [Warn] [Settings]: gui.show.bgColor 'False'
[13:50:41] [Warn] [Settings]: gui.alwaysShowUl 'False'
[13:50:41] [Warn] [Settings]: gui.scale '10'
[13:50:41] [Warn] [Settings]: gui.flag i*
[13:50:41] [Warn] [Settings]: view. antialiasing 'O'
[13:50:41] [Warn] [Settings]: view.showmodel 'True'
[13:50:41] [Warn] [Settings]: vmc.sender.ip "*********
[13:50:41] [Warn] [Settings]: vmc.sender.port '3333'
[13:50:41] [Warn] [Settings]: vmc.receiver.port '39539'
[13:50:41] [Warn] [Bootstrap]: Initializing AssetManager...

[13:50:41] [Warn] [Bootstrap]: Preparing ImageSource...
[13:50:41] [Info]: Load VRM Model: '/Users/Sarah/Desktop/Raahs.vrm'
[13:50:44] [Warn] [HolisticGraph]: Config Type = CPU
[13:50:44] [Warn] [HolisticGraph]: Min Detection Confidence = 0.5
[13:50:44] [Warn] [HolisticGraph]: Min Tracking Confidence = 0.5
[13:50:44] [Warn] [HolisticGraph]: Loading dependent assets...
[13:50:44] Verbose]: Waiting for WebCamTexture to start
[13:50:44] [Error] [HolisticSolution]: Failed to start ImageSource, exiting...

Does the camera work in OBS? If so you could try making an OBS virtual webcam and check if that works :)
https://m.youtube.com/watch?v=fj-ZWr37wFU

That worked, thanks! What a weird issue


Fix typo

Manually applied fix to dist since building created a lot of changes.

An updated dist has been build, thanks for the reminder.


Nc window styling

This PR adds a frameless window style to the application, removes auto-load for the devtools, and adds a finalized readme for the project.

YES! Well done, sir.


Delete ignored key from config.json

Since the exercise implementations are all in the exercises directory
we no longer need to ignore any non-exercise directories in the root
of the track.
See https://github.com/exercism/meta/issues/3 for context.

I've created another PR, #148, which normalizes all of the whitespace in the config.json so
that the change in this PR is minimized and easier to see.
If you merge the other PR first, I'll go ahead and rebase this one onto master.
Sorry about the noise!

I went ahead and merged in the config changes. I'll take a look at the other open PRs in this repo today, as well.


Control Elements for HMIP-WRC2 not available

DONT'T DELETE THIS.
Is your feature request related to a problem? Please describe.
For the HomematicIP Device HMIP-WRC2 is no Control Element available.
Describe the solution you'd like
Please provide the controls for the two channels for short press and long press respectively
Describe alternatives you've considered
A clear and concise description of any alternative solutions or features you've considered.
Additional context
Add any other context or screenshots about the feature request here.

This is not a bug in this integration. Pressed buttons on remotes can be used by device triggers in automations (see HA docs).
Also read this integration's docs carefully.


Exercises

Add a few exercises for dlang.

@tmccombs I only just saw that you had added more commits :( I didn't get a notification for this. (I think GitHub has recently added notifications on commits, so this shouldn't happen again).
I'm going to try to get this merged today.

This is merged in bf13398ec0c20440537368282a2e7473858e539a
Thank you so much!

I've invited you to the team that has commit on this repository. Thanks again!


[SPARK-33472][SQL][3.0] Adjust RemoveRedundantSorts rule order

Backport #30373 for branch-3.0.
What changes were proposed in this pull request?
This PR switched the order for the rule RemoveRedundantSorts and EnsureRequirements so that EnsureRequirements will be invoked before RemoveRedundantSorts to avoid IllegalArgumentException when instantiating PartitioningCollection.
Why are the changes needed?
RemoveRedundantSorts rule uses SparkPlan's outputPartitioning to check whether a sort node is redundant. Currently, it is added before EnsureRequirements. Since PartitioningCollection requires left and right partitioning to have the same number of partitions, which is not necessarily true before applying EnsureRequirements, the rule can fail with the following exception:
IllegalArgumentException: requirement failed: PartitioningCollection requires all of its partitionings have the same numPartitions.

Does this PR introduce any user-facing change?
No
How was this patch tested?
Unit test

Test build #131393 has started for PR 30438 at commit 775c4e8.

Kubernetes integration test starting
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/35997/

Kubernetes integration test status failure
URL: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder-K8s/35997/

Merged build finished. Test FAILed.

Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder-K8s/35997/
Test FAILed.

Test build #131393 has finished for PR 30438 at commit 775c4e8.

This patch fails due to an unknown error code, -9.
This patch merges cleanly.
This patch adds no public classes.

Merged build finished. Test FAILed.

Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/131393/
Test FAILed.


Is this project dead ?

It has pending issues and pull requests, but no activity for several months. Is this project dead ? Should we avoid to use it in production ?

Up to you - I review the repo every 2/3 months as it's something I've not used for many years. If someone wants to take ownership of the plugin over, I'm happy with that

Will you marge the pending pull requests ? Especially the ones that fix bugs.

Sure - I'll review them this evening and get them merged for you.
As I said, I won't be constantly working on this plugin, so if anyone wants ownership, let me know.

This plugin already works quite well, so I think it's okay.
But it's indeed would be great if at least PRs will be reviewed and merged.
Btw, why it's not used anymore? Switched to Webpack or Gulp?


Polyfill requestAnimationFrame to allow use in elm-repl

As discussed in https://github.com/elm-lang/elm-repl/issues/48. This looks right to me, but I haven't a clue how to test it. Any pointers?

Anything I can do to help move this forward?

It may make sense to first see whether https://github.com/evancz/elm-effects/pull/24 gets merged. If so, you will probably have to retarget your pull request, since there will be many merge conflicts.

Thanks @purcell!


Support Polymorphic Associated Objects

Sometimes there's certain behavior you'd like to share between multiple objects. However, Associated Object's design was purposefully written to only support associating with one distinct class.
This tries to shimmy that open a bit more, so you can do:
class Pricing < ActiveRecord::AssociatedObject::Polymorphic
end

class Post::Pricing < Pricing
end

class Comment::Pricing < Pricing
end

cc @garrettdimon @julianrubisch @natematykiewicz

An out-of-the-box alternative could be recommending using a concern like this:
class Post::Publisher < ActiveRecord::AssociatedObject
  include ::Publisher
end

class Comment::Publisher < ActiveRecord::AssociatedObject
  include ::Publisher
end

# app/models/concerns/publisher.rb
module Publisher
  extend ActiveSupport::Concern

  included do
    extension do
      # Feels a bit clunky though.
    end
  end

  # Any regular instance methods too
end

Not sure how I feel about the extension block nested in the included block, but it would work.

An out-of-the-box alternative could be recommending using a concern like this...

I agree about the nested extension block, but honestly, I kind of like how this uses AssociatedObject as organization but then uses Concerns for sharing. Again, without using it day-to-day in some production code, I'm not sure how strong my opinion is. I just think there's something beneficial about "Concepts" (AssociatedObject, Concern) having one specific task that they excel at (AO: Organizing, Concern: Sharing) so it's clear when to use which one.

@garrettdimon yeah, I like the way you put this. I also wonder how often people would need to inject an extension block in the shared concern, since it hooks into the class it might be very class specific — and then would be better placed in individual extension blocks in Post::Pricing and Comment::Pricing.

When we use extension it's always to set up callbacks to run on the model that use the associated object.

We ended up deciding this wasn't worth it and code sharing may be better handled in concerns for now.


Fix for additional labels for falco-exporter servicemonitor

Describe the bug
When deploying falco-exporter Helm chart with servicemonitor.additionallabels in values.yaml, the chart fails unless the value is a string, in which case the label is not created.
How to reproduce it
Edit values.yaml and add some servicemonitor additionallabels as map value(s).
serviceMonitor:
  # Enable the deployment of a Service Monitor for the Prometheus Operator.
  enabled: true
  additionalLabels:
    release: prom

⇒ helm upgrade --install falco-exporter . -f values.yaml -n falco
Error: UPGRADE FAILED: YAML parse error on falco-exporter/templates/servicemonitor.yaml: error converting YAML to JSON: yaml: line 10: mapping values are not allowed in this context

Expected behaviour
The additionallables should be created in the servicemonitor.  In this case "release: prom".
⇒ kctl -n falco get servicemonitors falco-exporter -o yaml
apiVersion: monitoring.coreos.com/v1
kind: ServiceMonitor
...
  labels:
  ...
    release: prom
  ...

Screenshots
N/A
Environment

Falco version:
Falco version: 0.24.0
Driver version: 85c88952b018fdbce2464222c3303229f5bfcfad

System info:

Cloud provider or hardware configuration:
GCP GKE Kubernetes v1.16.12

OS:
"machine": "x86_64",
"nodename": "gke-yolo-infra-dev-default-node-pool-4754cdf8-1s69",
"release": "4.19.112+",
"sysname": "Linux",
"version": "#1 SMP Thu May 21 12:32:38 PDT 2020"

Installation method:
Helm chart

Additional context
Here is the fix:
File: falco-exporter/templates/servicemonitor.yaml
see lines 8-10 under metadata.labels.
{{ if .Values.serviceMonitor.enabled }}
apiVersion: monitoring.coreos.com/v1
kind: ServiceMonitor
metadata:
  name: {{ include "falco-exporter.fullname" . }}
  labels:
    {{- include "falco-exporter.labels" . | nindent 4 }}
    {{- range $key, $value := .Values.serviceMonitor.additionalLabels }}
    {{ $key }}: {{ $value | quote }}
    {{- end }}
  namespace: {{ .Release.Namespace }}
spec:
  endpoints:
  - port: metrics
    {{- if .Values.serviceMonitor.interval }}
    interval: {{ .Values.serviceMonitor.interval }}
    {{- end }}
    {{- if .Values.serviceMonitor.scrapeTimeout }}
    scrapeTimeout: {{ .Values.serviceMonitor.scrapeTimeout }}
    {{- end }}
  selector:
    matchLabels:
      {{- include "falco-exporter.selectorLabels" . | nindent 6 }}
{{- end }}

Hi @rcompos
Good catch!
Could you open a PR to fix it?

I tried to open a PR but I don't have the privileges.  Thanks!


roccat talk fx (kone pure)

What are you experiencing an issue with?

[ ] Aurora
[ ] Aurora supported game, (Fill in the game)
[ ] Aurora Wrapper
[ ] Aurora Profile
[X] Aurora supported device, (roccat kone pure)
[ ] Aurora Scripts
[ ] Aurora Updater
[ ] Aurora Lighting issue
[ ] Other, (Fill in another issue here)

What kind of an issue is it?

[ ] Crash
[ ] Performance problems
[ ] Visual bug
[ ] Localization issue
[ ] Enhancement suggestion
[X] Device issue
[ ] Other, (Fill in another type of issue here)

Expected behavior:
The light color should change.
Actual behavior:
Nothing happens.
I know that you can control the led. Because I could change the color by using this repository (by using its test file):
https://github.com/CosminLazar/roccat-talk-csharp
I don't know why but the key effect is not working. (no breathing, blinking...)
What is the version of Aurora you are experiencing this issue with?

My version is... (dev4-349)

I don't think the current implementation of the SDK supports the Roccat mice, I'll try and have a look into this and get it working for you.


No datasets have been produced after first feedstock run

Hi @andersy005, @cisaacstern ! So no datasets have been produced after the pull request has been merged, I do not know what went wrong : https://pangeo-forge.org/dashboard/feedstock/87, it only says that the status is failed ... Do you have any insights on this ? Is it possible to run it again ?
Originally posted by @auraoupa in https://github.com/pangeo-forge/staged-recipes/issues/189#issuecomment-1296722166

@auraoupa, The failures seem to be related to some connectivity issue
 Traceback (most recent call last):
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 284, in _execute
      response = task()
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 357, in <lambda>
      lambda: self.create_worker().do_instruction(request), request)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 597, in do_instruction
      return getattr(self, request_type)(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 635, in process_bundle
      bundle_processor.process_bundle(instruction_id))
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1003, in process_bundle
      input_op_by_transform_id[element.transform_id].process_encoded(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 227, in process_encoded
      self.output(decoded_value)
    File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1507, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected [while running 'Start|cache_input|Reshuffle_000|prepare_target|Reshuffle_001|store_chunk|Reshuffle_002|finalize_target|Reshuffle_003/cache_input/Execute-ptransform-56']
  ,

    a6170692e70616e67656f2d66-10310800-yvxa-harness-wbm9
        Root cause: Traceback (most recent call last):
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected

  During handling of the above exception, another exception occurred:

  Traceback (most recent call last):
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 284, in _execute
      response = task()
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 357, in <lambda>
      lambda: self.create_worker().do_instruction(request), request)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 597, in do_instruction
      return getattr(self, request_type)(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 635, in process_bundle
      bundle_processor.process_bundle(instruction_id))
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1003, in process_bundle
      input_op_by_transform_id[element.transform_id].process_encoded(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 227, in process_encoded
      self.output(decoded_value)
    File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1507, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected [while running 'Start|cache_input|Reshuffle_000|prepare_target|Reshuffle_001|store_chunk|Reshuffle_002|finalize_target|Reshuffle_003/cache_input/Execute-ptransform-56']
  ,

    a6170692e70616e67656f2d66-10310800-yvxa-harness-wbm9
        Root cause: Traceback (most recent call last):
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected

  During handling of the above exception, another exception occurred:

  Traceback (most recent call last):
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 284, in _execute
      response = task()
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 357, in <lambda>
      lambda: self.create_worker().do_instruction(request), request)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 597, in do_instruction
      return getattr(self, request_type)(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 635, in process_bundle
      bundle_processor.process_bundle(instruction_id))
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1003, in process_bundle
      input_op_by_transform_id[element.transform_id].process_encoded(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 227, in process_encoded
      self.output(decoded_value)
    File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1507, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected [while running 'Start|cache_input|Reshuffle_000|prepare_target|Reshuffle_001|store_chunk|Reshuffle_002|finalize_target|Reshuffle_003/cache_input/Execute-ptransform-56']
  ,

    a6170692e70616e67656f2d66-10310800-yvxa-harness-wbm9
        Root cause: Traceback (most recent call last):
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected

  During handling of the above exception, another exception occurred:

  Traceback (most recent call last):
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 284, in _execute
      response = task()
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 357, in <lambda>
      lambda: self.create_worker().do_instruction(request), request)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 597, in do_instruction
      return getattr(self, request_type)(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 635, in process_bundle
      bundle_processor.process_bundle(instruction_id))
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1003, in process_bundle
      input_op_by_transform_id[element.transform_id].process_encoded(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 227, in process_encoded
      self.output(decoded_value)
    File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output
    File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1491, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 623, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "apache_beam/runners/common.py", line 1581, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    File "apache_beam/runners/common.py", line 1694, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process
    File "apache_beam/runners/common.py", line 1419, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 1507, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    File "apache_beam/runners/common.py", line 1417, in apache_beam.runners.common.DoFnRunner.process
    File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process
    File "/usr/local/lib/python3.9/dist-packages/apache_beam/transforms/core.py", line 1956, in <lambda>
    File "/usr/local/lib/python3.9/dist-packages/pangeo_forge_recipes/executors/beam.py", line 40, in exec_stage
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/recipes/xarray_zarr.py", line 156, in cache_input
      config.storage_config.cache.cache_file(
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 173, in cache_file
      _copy_btw_filesystems(input_opener, target_opener)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/pangeo_forge_recipes/storage.py", line 43, in _copy_btw_filesystems
      data = source.read(BLOCK_SIZE)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 590, in read
      return super().read(length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/spec.py", line 1643, in read
      out = self.cache._fetch(self.loc, self.loc + length)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/caching.py", line 377, in _fetch
      self.cache = self.fetcher(start, bend)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 111, in wrapper
      return sync(self.loop, func, *args, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 96, in sync
      raise return_result
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/asyn.py", line 53, in _runner
      result[0] = await coro
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/fsspec/implementations/http.py", line 624, in async_fetch_range
      r = await self.session.get(self.url, headers=headers, **kwargs)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client.py", line 560, in _request
      await resp.start(conn)
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/client_reqrep.py", line 899, in start
      message, payload = await protocol.read()  # type: ignore[union-attr]
    File "/srv/conda/envs/notebook/lib/python3.9/site-packages/aiohttp/streams.py", line 616, in read
      await self._waiter
  aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected [while running 'Start|cache_input|Reshuffle_000|prepare_target|Reshuffle_001|store_chunk|Reshuffle_002|finalize_target|Reshuffle_003/cache_input/Execute-ptransform-56']
timestamp: '2022-10-31T15:16:38.664727404Z'

This is most likely the remote server not being happy with multiple requests being done asynchronously due to dataflow's scaling... Unfortunately, i don't know how to address this issue, but will let others chime in cc @rabernat / @martindurant / @yuvipanda

At first I thought you may need rate limiting in the pipeline (something like https://github.com/google/weather-tools/blob/0322cac4d679c105999a96cf9c3fced71e4561ae/weather_mv/loader_pipeline/util.py#L291, Charles and I have discussed this before on a separate issue). However, from the trace, it looks like this is an issue with copying data from their filesystem to ours. I'm interested to hear other's thoughts on the matter.

Note that async method like cat  allow for a batch_size argument to control hoe many requests are sent at a time. However, here we are using the stateful file API, so parallelism is controlled entirely outside of fsspec.

thank you for looking into this, @auraoupa! i'm available all day today and tomorrow, and would be happy to help with the new recipe runs. Ping me whenever you are ready for us to try again.

Hi @andersy005, I did not give up on these recipes yet ! There have been some modifications on our opendap in order to fix the connectivity issues, could you give it a last try ? Then if it does not work I will find another place to host the data ... Thanks for your help !

Hi @andersy005 , @cisaacstern , @rabernat ! Sorry to be pushy, could you please give this recipe a last try ? If it still does not work I will create a new recipe with a different hosting opendap ... Thanks !

Hi @cisaacstern and @yuvipanda ! Would it be possible to try my recipe a last time so I know wether the opendap  on which my data are currently hosted still has connectivity issues ? Thanks

👋 Hi @auraoupa, thanks for being persistent here, and apologies for the (terribly) delayed reply. As you can see, Pangeo Forge (both the software, and the community) does not support time-sensitive requests particularly well. In part, this is a product of our very small maintainer pool, and also it is partially an assumption of the platform design that the public data we are pulling will be (more or less) "always available" ... this assumption breaks down of course, in the case of pulling from bandwidth-constrained sources.
All that being said, I am of course happy to trigger a re-run now, which I will do by opening (then merging) a PR which makes some arbitrary change to the code. (A merged PR is currently our only switch for triggering a new run.) We can check back on this issue when this new run completes.
And again, apologies for the tremendous delay and thank you for keeping us accountable here.

Thanks @cisaacstern for this test ! I guess I have to find another place to store the data then ... One idea though, do you think it could help if we tried just one of the 3 sub-recipes ? Or rearrange the files so that there is not so many of them ?

@auraoupa, running just one of the sub-recipes is a good thought, though unfortunately is not currently supported. (This would be a good future feature to develop under the general heading of concurrency limits.)

Or rearrange the files so that there is not so many of them ?

This is a promising idea. The production run will make one request per file, so yes, reducing file count will also reduce concurrency. If files are too large, however, we run the risk of long-running transfers with dropped connections.
How many files (of what sizes) does each sub-recipe currently have?
As a general guideline, I'd say if we can reduce number of files by at least 5x without pushing per-file sizes over 10 GB, it's worth a shot.

Thanks @cisaacstern for the suggestions ! I will then make monthly files instead of daily ones and maybe submit a new recipe with only one dataset at a time, which will be 12 files (instead of 3x 365 files), around 8Gb each !

@auraoupa, sounds good... this could conceivably work!
Perhaps this is clear, but in case not, please make the PR as an edit to the file feedstock/recipe.py in this repo (not to staged-recipes).

Hi @cisaacstern, I hope you had nice end of year and wish you the best for 2023 ! I rewrote the recipe so we can try with fewer files at a time in the pull request #6 , could you please merge it ? Thanks !

Hi @cisaacstern ! Last try for this recipe in the pull request #6 , this time the files are smaller than 2Gb each and there are 73 of them ...


How to get result in as NSDictionary.

Hey @yannickl  great work and thanks for save my time,
I completely integrate this lib.  and it's work perfectly but wen i got QR Response i cant handle it, i want to get result in NSDictionary how to convert ?
@All any have solution ? Please help me.

The callback returns a QRCodeReaderResult. You can manage the value and metadataType as you want then.

@yannickl  i change value as NSDictionary also metadataType but i facing my of file error and i cant solve and i facing

QRCodeReader.swift

`public
func metadataOutput(_ output: AVCaptureMetadataOutput, didOutput metadataObjects: [AVMetadataObject], from connection: AVCaptureConnection) {
sessionQueue.async { [weak self] in
guard let weakSelf = self else { return }
  for current in metadataObjects {
    if let _readableCodeObject = current as? AVMetadataMachineReadableCodeObject {
      if _readableCodeObject.stringValue != nil {
        if weakSelf.metadataObjectTypes.contains(_readableCodeObject.type) {
            guard weakSelf.session.isRunning, let sVal = _readableCodeObject.stringValue else { return }

          if weakSelf.stopScanningWhenCodeIsFound {
            weakSelf.session.stopRunning()

            DispatchQueue.main.async {
              weakSelf.lifeCycleDelegate?.readerDidStopScanning()
            }
          }

          let scannedResult = QRCodeReaderResult(value: sVal, metadataType:_readableCodeObject.type.rawValue)

          DispatchQueue.main.async {
            weakSelf.didFindCode?(scannedResult)
          }
        }
      }
    }
    else {
      weakSelf.didFailDecoding?()
    }
  }
}

}` .   i got this error Cannot convert value of type 'String' to expected argument type 'NSDictionary' form

let scannedResult = QRCodeReaderResult(value: sVal, metadataType:_readableCodeObject.type.rawValue)

how to resolve this issue if you have done so please share with  me code .


New iter_generate for OPS 2.0

One of the things I want to do in OPS 2.0 is simplify code in API-breaking ways, when the API isn't something that is widely used. One case of this is DynamicsEngine.iter_generate. The existing iter_generatehas a huge complexity rating (McCabe cyclomatic complexity of 46; CodeClimate "cognitive complexity" of 92). This comes because it tries to implement a bunch of user-facing options for error handling into one catch-all function, instead of letting the client code handle the errors. This is all the stuff about how to handle NaNs or max-length error (whether to restart/retry/etc.)
In path sampling, many of those options would be just wrong. A trajectory that generates a NaN is a rejected trajectory. Retrying will bias the sampling. In addition, when I tried to write tests for it, it became clear that some of that functionality isn't even implemented correctly.
So this PR rewrites iter_generate without the extra error handling functionality. That error handling should be done in the calling code. We raise errors that should make it clear to calling code what the problem is; special treatments in case of certain error types can be done by calling code (this is never something that should be done on a per-engine level, but something that should be done on a situational basis).
There are two places where engine writers can change the error handling:

engine.is_valid_snapshot(): Check whether the created snapshot is valid. Generally will just return a bool. If you want to use the default error behavior (raise an EngineError), this is all you need to change.
engine.snapshot_error_handler(): If you want to modify the error in some way, or if there are some errors that you can recover from, do that here. If you want an error to be raised, then return the error. If you can recover from the error and create a valid snapshot, then return the valid snapshot.

For most users, this makes no difference. It means that under the hood we're using a different function. The API break is the drop of engine-level support for error handling, and a small change in the call signature of iter_generate (removing the intervals parameter). I don't think anyone will miss these things.

[x] Code for new iter_generate
[x] Use new iter_generate for all tests
[ ] Add support for correcting snapshot
[ ] Unit tests for new iter_generate; full coverage
[ ] Update docs on writing engines
[ ] Remove options for NaN handling from engines
[ ] Remove docstrings about NaN handling from engines

There's a weird thing in the unit tests for the minus mover. I changed some behavior there, but I honestly don't understand why the previous behavior was occurring.
Essentially, the minus move consists of the replica exchange stage followed by an extension stage. There's a test for the case that the minus move fails because the extension hits max length, which uses this code. For some reason, the old test checked that the extension trajectory was of a length longer than the engine's maximum. I don't know why that would be. The test itself also modified the engine's error handling (setting 'on_max_length' to 'stop', not 'fail'), so I expect that was part of it. If anyone else has an idea as to why I did it that way, please let me know.
Relevant code is in tests for both minus mover and single replica minus mover:
https://github.com/openpathsampling/openpathsampling/blob/c67edf7c42f440361298a542c54f2e1fd1bf8631/openpathsampling/tests/test_pathmover.py#L1355-L1358
https://github.com/openpathsampling/openpathsampling/blob/c67edf7c42f440361298a542c54f2e1fd1bf8631/openpathsampling/tests/test_pathmover.py#L1517-L1522

Not sure why we're getting @codecov updates on a branch where the CI doesn't report coverage... I wouldn't trust the data.


Support Multi Platform Project builds

Hi,
We use sarif4k in our MPP project: https://github.com/saveourtool/save-cli.
For it we forked the project and changed only gradle build project (and location of source codes).
We would like to contribute this change to your project.

Sounds good to me. Thanks for your contribution! 😊


Update stable version in repo from 0.5.6 to 0.6.1

Think about update stable version to 0.6.1
Version: stable=0.5.6 (315 days old) => latest=0.6.1 (302 days old)
Installs: stable=12 (11.65%), latest=4 (3.88%), total=103
Click to edit

done, updated to 0.6.5


Can't add "Flow" plugin to web app (https://app.diagrams.net/)

Preflight Checklist

[x] I agree to follow the Code of Conduct that this project adheres to.
[x] I have searched the issue tracker for a feature request that matches the one I want to file, without success.

Describe the bug
I'm attempting to use the 'Flow' plugin for animated diagraming.
When I try to include the 'Flow' plugin from the plugins screen (Extras > Plugins > Add > Flow) it acts like it's worked but then an "Undefined" item is added to the plugin list. Shown here:
When I close the dialog and go back in, its stated as "null" (shown in screen shot above as well - all the previous attempts to add 'Flow').
This is happening on the web app but I also cannot add 'Flow' plugin to the desktop app.
To Reproduce
Steps to reproduce the behavior:

Go to 'Extras' menu
Click on 'Plugins'
Click on 'Add'
Select 'Flow' from the dropdown list and press Ok
See error

Expected behavior
I expect 'Flow' to be added and available for me to use.
Screenshots
If applicable, add screenshots to help explain your problem.

draw.io version (In the Help->About menu of the draw.io editor):

draw.io version 21.7.2

Desktop (please complete the following information):

OS: Windows 10
Browser Chrome
Browser Version 116.0.5845.111

I tested the problem in incognito/private mode with all browser extensions switched off, write "yes" below:

YES

Additional context
I tried this on the desktop version of Drawio also and have problems there too:

The flow plugin is no longer needed (and will be removed from that list). You can enable the animation from here:


stable 20190314 2019-03-15 (89) does not start

ubuntu 16.04 with unity7 / intel graphics
$ openra.ra
Platform is Linux
Engine version is release-20190314
Using SDL 2 with OpenGL renderer
Desktop resolution: 1920x1080
No custom resolution provided, using desktop resolution
Using resolution: 1920x1080
Using window scale 1.00
Exception of type `System.InvalidOperationException`: Can not create OpenGL context. (Error: Invalid window)
  at OpenRA.Platforms.Default.Sdl2GraphicsContext.InitializeOpenGL () [0x00066] in <a4debf887ee14158b13d4169d50b2963>:0
  at OpenRA.Platforms.Default.ThreadedGraphicsContext.RenderThread (System.Object contextObject) [0x0002d] in <a4debf887ee14158b13d4169d50b2963>:0
  at System.Threading.ThreadHelper.ThreadStart_Context (System.Object state) [0x0002c] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ExecutionContext.RunInternal (System.Threading.ExecutionContext executionContext, System.Threading.ContextCallback callback, System.Object state, System.Boolean preserveSyncCtx) [0x0008d] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ExecutionContext.Run (System.Threading.ExecutionContext executionContext, System.Threading.ContextCallback callback, System.Object state, System.Boolean preserveSyncCtx) [0x00000] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ExecutionContext.Run (System.Threading.ExecutionContext executionContext, System.Threading.ContextCallback callback, System.Object state) [0x00031] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ThreadHelper.ThreadStart (System.Object obj) [0x00012] in <8f2c484307284b51944a1a13a14c0266>:0

[ERROR] FATAL UNHANDLED EXCEPTION: System.InvalidOperationException: Can not create OpenGL context. (Error: Invalid window)
  at OpenRA.Platforms.Default.Sdl2GraphicsContext.InitializeOpenGL () [0x00066] in <a4debf887ee14158b13d4169d50b2963>:0
  at OpenRA.Platforms.Default.ThreadedGraphicsContext.RenderThread (System.Object contextObject) [0x0002d] in <a4debf887ee14158b13d4169d50b2963>:0
  at System.Threading.ThreadHelper.ThreadStart_Context (System.Object state) [0x0002c] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ExecutionContext.RunInternal (System.Threading.ExecutionContext executionContext, System.Threading.ContextCallback callback, System.Object state, System.Boolean preserveSyncCtx) [0x0008d] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ExecutionContext.Run (System.Threading.ExecutionContext executionContext, System.Threading.ContextCallback callback, System.Object state, System.Boolean preserveSyncCtx) [0x00000] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ExecutionContext.Run (System.Threading.ExecutionContext executionContext, System.Threading.ContextCallback callback, System.Object state) [0x00031] in <8f2c484307284b51944a1a13a14c0266>:0
  at System.Threading.ThreadHelper.ThreadStart (System.Object obj) [0x00012] in <8f2c484307284b51944a1a13a14c0266>:0
Red Alert has encountered a fatal error.
Please refer to the crash logs and FAQ for more information.

Log files are located in ~/.openra/Logs
The FAQ is available at http://wiki.openra.net/FAQ

Thanks for the report. This is now fixed in the stable channel (I hope).

yep, werks now! thanx

excellent :-) thanks again


Update phrasing :)

If you're a contributor, DM me if you have any questions about this pull.

Sorry for the delay, thanks for the PR


pypi-mirror: init at 4.0.6

Motivation for this change
Things done

[x] Tested using sandboxing (nix.useSandbox on NixOS, or option sandbox in nix.conf on non-NixOS linux)
Built on platform(s)

[x] NixOS
[ ] macOS
[ ] other Linux distributions

[ ] Tested via one or more NixOS test(s) if existing and applicable for the change (look inside nixos/tests)
[x] Tested compilation of all packages that depend on this change using nix-shell -p nixpkgs-review --run "nixpkgs-review wip"
[x] Tested execution of all binary files (usually in ./result/bin/)
21.11 Release Notes (or backporting 21.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.

Result of nixpkgs-review pr 134276 at 975dce04 run on aarch64-linux 1

2 packages built successfully:

python38Packages.python-pypi-mirror
python39Packages.python-pypi-mirror

1 suggestion:

warning: no-python-tests
Test runner could not discover any test cases: ‘Ran 0 tests in 0.000s’
Near pkgs/development/python-modules/python-pypi-mirror/default.nix:21:0:
   |
21 |     description = "A script to create a partial PyPI mirror";
   | ^

Result of nixpkgs-review pr 134276 run on x86_64-linux 1

2 packages built:

python38Packages.python-pypi-mirror
python39Packages.python-pypi-mirror

This looks more like a CLI tool than a module. How about adding it to all-packages.nix (e. g., pypi-mirror = with python3.pkgs; toPythonApplication python-pypi-mirror;)?

done


listingsItems 2021-08-01

This PR came at perfect timing! Thank you so much, @altruer! :cake:

@IonicaBizau will you you merge it, please?

@altruer, thanks for the PR! Merged and part of new release v0.6.0


pc: update description + add nodedescriptionpath

This patch updates the soletta's .pc description to some more acurate
text and introduces the nodedescriptionpath variable so the lib's users
may find out where the json descriptions are installed.
Signed-off-by: Leandro Dorileo<EMAIL_ADDRESS>

:+1:, tks

ok, applied.


Adding a custom action node to my custom behavior tree

Hello,
after the great help with the how to load a custom behavior tree, I'm now facing the problem of registering my own action nodes, so that the nav2 behavior tree can see them. I tried to do it like in the tutorial on the nav2 page (https://docs.nav2.org/plugin_tutorials/docs/writing_new_bt_plugin.html) but I'm unable to do it like that.
So now I would really appreciate some help on how to do it. My Code for my test plugin is below and I'm using Ubuntu 22.04 and ROS2 Humble. The file are named test.cpp, test.hpp and own_behavior_tree.xml
I can build the plugin without any problems and also source it to my project, but as soon as my launch file reaches the point of loading the behavior tree, is freezes into an endless loop.
<root main_tree_to_execute="MainTree">
  <BehaviorTree ID="MainTree">
    <MyCustomAction input_data="Hello World!" />
  </BehaviorTree>
</root>

#ifndef MY_NAV2_BT_PLUGIN__MY_CUSTOM_ACTION_NODE_HPP_
#define MY_NAV2_BT_PLUGIN__MY_CUSTOM_ACTION_NODE_HPP_

#include "behaviortree_cpp_v3/action_node.h"

namespace my_nav2_bt_plugin
{
  class MyCustomAction : public BT::SyncActionNode
  {
  public:
    MyCustomAction(const std::string &name, const BT::NodeConfiguration &config)
      : BT::SyncActionNode(name, config) {}

    // Method required by BehaviorTree.CPP library
    static BT::PortsList providedPorts()
    {
      return { BT::InputPort<std::string>("input_data") };
    }

    // Main method where the action is executed
    BT::NodeStatus tick() override
    {
      std::string input_data;
      if (!getInput<std::string>("input_data", input_data)) {
        throw BT::RuntimeError("missing required input [input_data]");
      }

      // Your custom logic here
      std::cout << "Custom action node: " << input_data << std::endl;

      return BT::NodeStatus::SUCCESS;
    }
  };
}  // namespace my_nav2_bt_plugin

#endif  // MY_NAV2_BT_PLUGIN__MY_CUSTOM_ACTION_NODE_HPP_

#include "my_nav2_bt_plugin/test.hpp"
#include "behaviortree_cpp_v3/bt_factory.h"

// This is the entry point that registers the plugin with BehaviorTree.CPP
BT_REGISTER_NODES(factory)
{
  factory.registerNodeType<my_nav2_bt_plugin::MyCustomAction>("MyCustomAction");
}

cmake_minimum_required(VERSION 3.5)
project(my_nav2_bt_plugin)

# Find dependencies
find_package(ament_cmake REQUIRED)
find_package(rclcpp REQUIRED)
find_package(nav2_behavior_tree REQUIRED)
find_package(behaviortree_cpp_v3 REQUIRED)

# Add include directories
include_directories(include)

# Create the library for the custom BT plugin
add_library(${PROJECT_NAME} SHARED src/test.cpp)

# Link against required libraries
ament_target_dependencies(${PROJECT_NAME}
  rclcpp
  nav2_behavior_tree
  behaviortree_cpp_v3
)

# Install the library and the headers
install(
  TARGETS ${PROJECT_NAME}
  LIBRARY DESTINATION lib
)

install(
  DIRECTORY include/
  DESTINATION include/${PROJECT_NAME}
)

ament_package()

bt_navigator:
  ros__parameters:
    use_sim_time: True
    global_frame: map
    robot_base_frame: base_link
    odom_topic: /odom
    default_nav_to_pose_bt_xml: /home/bastian/Documents/own_navigation/install/gazebo_simulation/share/gazebo_simulation/xml/own_behavior_tree.xml
    bt_loop_duration: 10
    default_server_timeout: 20
    plugin_lib_names:
    - my_nav2_bt_plugin
    - nav2_compute_path_to_pose_action_bt_node
    - nav2_compute_path_through_poses_action_bt_node
    - nav2_follow_path_action_bt_node
    - nav2_back_up_action_bt_node
    - nav2_spin_action_bt_node
    - nav2_wait_action_bt_node
    - nav2_clear_costmap_service_bt_node
    - nav2_is_stuck_condition_bt_node
    - nav2_goal_reached_condition_bt_node
    - nav2_goal_updated_condition_bt_node
    - nav2_initial_pose_received_condition_bt_node
    - nav2_reinitialize_global_localization_service_bt_node
    - nav2_rate_controller_bt_node
    - nav2_distance_controller_bt_node
    - nav2_speed_controller_bt_node
    - nav2_truncate_path_action_bt_node
    - nav2_goal_updater_node_bt_node
    - nav2_recovery_node_bt_node
    - nav2_pipeline_sequence_bt_node
    - nav2_round_robin_node_bt_node
    - nav2_transform_available_condition_bt_node
    - nav2_time_expired_condition_bt_node
    - nav2_distance_traveled_condition_bt_node
    - nav2_single_trigger_bt_node
    - nav2_is_battery_low_condition_bt_node
    - nav2_navigate_through_poses_action_bt_node
    - nav2_navigate_to_pose_action_bt_node
    - nav2_remove_passed_goals_action_bt_node
    - nav2_planner_selector_bt_node
    - nav2_controller_selector_bt_node
    - nav2_goal_checker_selector_bt_node

Please ask on robotics stack exchange, this is no the place for code help for customization add ons. You can see many examples of how to work with BT plugins in Nav2's behavior tree package, open navigation's opennav_coverage and opennav_docking packages, and other community projects for reference.


GFA license missing

One branch contains the source code of https://github.com/szapp/GothicFreeAim
Please fulfill the license conditions when using GFA in your project and include the license file.

Sorry, didn't ment to, we were just trying to implement it. Don't mind this github anymore, it's pointless atm. When and if I implemente GFA i will make sure to credit you for that.


[PD] Reflect on your development so far

Coursework content
You have now learned many new things: tools, skills, and programming language. Considering this, reflect on your development.
Estimated time in hours
0.5
What is the purpose of this assignment?
Reflect and celebrate how much you have developed your knowledge so far.
How to submit

Think about 1 achievement you had and 1 professional skill (not technical skill) you still want to develop.
Write a paragraph about these two: what are they AND why do you think you did well OR still have to learn them?
Share this with your class on the thread about this coursework. If the thread doesn't exist yet, you are the first and can create it
Read your fellow trainees' messages and react to them with emojis that support them or are relevant to their content.
Copy the link to the Slack message you posted on this ticket
Copy a screenshot of the message you posted on this ticket

Kamino cloned this issue to FrenchFry36/Coursework-Planner

Kamino cloned this issue to Ebtesammm/Coursework-Planner

Kamino cloned this issue to kostiantynkovalchuk/Coursework-Planner

Kamino closed and cloned this issue to DelwinMansur/DelwinMansur-Coursework-Planner


issue-42 Implement fragment columns for lead-generation section

The lead generation "Speak to an expert" black section, just above the footer on almost all pages, has been implemented now as a fragment. This will allow it to be included on the many pages where it is included on the Vonage site.
Getting the black background working with the fragment required a change to scripts.js so that the class of the fragment was copied up to the fragment-container.
This PR also includes some change to footer and cards to remove use of the :has selector and to fix some other behavior.
Fix #42
Test URLs:

Before: https://main--vonage--hlxsites.hlx.page/unified-communications/
After: https://issue-42-lead-gen--vonage--hlxsites.hlx.page/unified-communications/

@jimaldous I'm going to approve this, but try to keep misc changes out of a specific ticket. That way things don't get so intertwined.


Fix default persistent file location

The default Android persistent file location should be "internal", as documented in the file plugin's README.md. The value was unintentionally changed in a recent commit.

@infil00p please review

@jasongin +1
Yeah, the change to compatibility looks like a mistake. It is supposed to be "internal" as of the 3.0.0 release.e


Clarification on resourcing of project

I've noticed a big slowdown in commits over the last month, with 0 updates on master , and only 2 commits on other branches. Has Google scaled back their resourcing of this project, or is this just a short term lull in activity? MDL is great, but still a work in progress in terms of full coverage of the material design spec. Is Google still committed to pushing towards as complete a coverage of MD as possible?

The core team is focusing on getting V2 planned out right now. Also with I/O and other events with the team involved happening that means less time for this project right now.
V1 is effectively in a community-support place right now except for major bugs. V2 is the core teams current primary focus.

Thanks , that is what I was hoping to hear! Seeing the repo activity drop off sharply recently, I was worried the project had been de-resourced, glad to hear that is not the case, and that progress is being made towards V2.


Support for multiple, root-level tsconfigs

https://github.com/microsoft/TypeScript/pull/48189 and https://github.com/microsoft/TypeScript/issues/35395#issuecomment-1239843287 are really nice new additions, but ones that are incredibly limited by my inability to have VS Code be aware of the fact that some files are using a different TS Config.
Sure, I could use different TS Configs in different folders so findup resolves rules correctly; however, that's not always ideal!Imagine a typical components folder full of folders that house component source code, test files, and maybe Storybook files...
component
        ├── __tests__
        |       └ component.test.tsx
        ├── __stories__
        |       └ component.stories.tsx
        └── component.tsx

Different file suffixes and different contexts ripe for developer experience improvements; however, to actually provide different tsconfig contexts to these files, I'd need:
component
        ├── __tests__
        |       ├ tsconifg.test.json
        |       └ component.test.tsx
        ├── __stories__
        |       ├ tsconifg.stories.json
        |       └ component.stories.tsx
        └── component.tsx

This is untenable. Instead, I wanted to suggest the ability to map multiple TS Configs to VS Code where in-project collisions are checked for (so no 2 tsconfigs read the same file). If there are no collisions, VS Code will choose the correct tsconfig regarding the file in view.

My team has the same issue.
We try to co-locate our UI tests with our product code, and each set has its own tsconfig file which cannot be shared.
I added the jest-expect-message library to be used by our tests but Visual Studio Code keeps showing a type error, even though our external TypeScript type check succeeds.
After looking at the content of tsserver.log, I can tell Visual Studio Code is using the wrong tsconfig for the test.


Cross build to Scala 3

The main issue is that macros are not compatible. We'll need to use the macro system maybe eitheer in core or a new macro3 module. Macro annotations do not exist in Scala 3.

Maybe an intermediate milestone could be to cross build the core module

I'd love to contribute, do you think this can be split in a few tasks?

I'd love to contribute, do you think this can be split in a few tasks?

Yeah maybe one per module, what do you think?

@cquiroz I created a few issues and linked them to this ticket. I think it is best to start with core.


Polish up kafka,nats,activemq,rabbitmq plugins to set peer at comsumer side

[x] If this pull request closes/resolves/fixes an existing issue, replace the issue number. Closes #.
[x] Update the CHANGES log.

We  have optimized  MQ Topology analysis and  virtual mq  in https://github.com/apache/skywalking/pull/9911
Let's  fill  peer   to  consumer EntrySpan  for all MQ plugins

@pg-yang So, I could begin the 8.13.0 release?

I could begin the 8.13.0 release?

Yes , I want to optimize activeMQ in next release  ,   I'm  reading the doc . OK ?

Yes, that is not urgent.